Google Git
Sign in
apache / fluss-rust / HEAD
  1. 8b583a8 feat: introduce list partitions in cpp binding (#260) by yuxia Luo · 11 hours ago main
  2. 9af12ea feat: support unsubscribe partition (#257) by yuxia Luo · 14 hours ago
  3. 6de2cde feat: Support drop_table, partitions and offsets methods in python bindings (#150) by Anton Borisov · 16 hours ago
  4. 52dca9f chore: rename subscribe_batch to subscribe_buckets (#255) by yuxia Luo · 16 hours ago
  5. b18cffb chore: refator to builder pattern to create log scanner for CPP (#249) by Anton Borisov · 16 hours ago
  6. 90cc35a chore: Change upsert and delete to use read only self reference by using mutex to guard mutable encoders (#247) by Keith Lee · 17 hours ago
  7. 0e50dc2 feat: Support different poll methods (#246) by Anton Borisov · 17 hours ago
  8. 31d5df5 feat: introduce kv tables support in python (#239) by Anton Borisov · 2 days ago
  9. 5574d55 chore: Reject table scan for INDEXED format or KV table (#238) by Keith Lee · 2 days ago
  10. 9877993 feat: support subscribe partition in cpp binding (#236) by yuxia Luo · 2 days ago
  11. 7d794f7 feat: add table partition scanning (#222) by Miao · 2 days ago
  12. ece3834 chore: accept Into<String> to improve api usage (#234) by yuxia Luo · 3 days ago
  13. 0cf25e6 chore: make Config#bootstrap_server required (#233) by yuxia Luo · 3 days ago
  14. e5adc3d feat: introduce scan record batch in cpp (#230) by yuxia Luo · 3 days ago
  15. a05f996 feat: support list partition offset in cpp binding (#231) by yuxia Luo · 3 days ago
  16. 4d50eb2 feat: support list offset for partitioned table (#229) by yuxia Luo · 5 days ago
  17. 81dd6e0 feat: support produce partitioned table (#228) by yuxia Luo · 7 days ago
  18. 83fa0aa feat: Implement partitioning in Upsert / Lookup (#220) by Keith Lee · 7 days ago
  19. 00f4aca feat: support scan from oss (#217) by yuxia Luo · 8 days ago
  20. 0b53d37 chore: support estimated_size_in_bytes for write batch (#219) by yuxia Luo · 9 days ago
  21. fd8e9c4 chore: Fix async fn panic in CancellationSafeFuture when future completes by yuxia Luo · 9 days ago
  22. 2b9d1d8 chore: minor fix for rust code (#218) by yuxia Luo · 9 days ago
  23. 916f64c [chore] Implement is_auto_partitioned method in table.rs (#48) by Junbo Wang · 9 days ago
  24. c1dfcee chore: Introduce PartitionGetter and Partition utils (#214) by Keith Lee · 10 days ago
  25. 7cc7bf6 chore: Add blocking poll into python bindings (#154) by Anton Borisov · 11 days ago
  26. 9d3917c chore: introduce SecurityTokenManager to update token in the background (#213) by yuxia Luo · 11 days ago
  27. 1bc399b test: add it for produce & scan log for all supported datatypes (#205) by SkylerLin · 11 days ago
  28. 017bb15 chore: introduce new with capacity to align generic row with java side (#212) by yuxia Luo · 12 days ago
  29. f7f3abf feat: Support Arrow append operations for decimals, temporal types in Python (#206) by Anton Borisov · 12 days ago
  30. 2b5fc64 chore: add more info for RecordBatches (#211) by Anton Borisov · 12 days ago
  31. fdd5296 feat: Implement Admin APIs for partitioning (#208) by Keith Lee · 13 days ago
  32. 7ee9bfe feat: introduce priority queue for downloading remote segments (#187) by Anton Borisov · 13 days ago
  33. e09250c test: add it test for put & get kv for all supported datatypes (#204) by SkylerLin · 14 days ago
  34. d76eb28 test: Kv Table Integration tests (#192) by Keith Lee · 2 weeks ago
  35. 7c5af55 chore: invalidate leader info on stale metadata error when handling fetch response (#189) by AlexZhao · 2 weeks ago
  36. ed646e2 feat: Arrow serialization for decimal and temporal types (#196) by Anton Borisov · 2 weeks ago
  37. eaf5a24 feat: Fix TableLookup so that SchemaId field bytes are not passed to CompactedRow::from_bytes(), these fields can be skipped as current rust client implementation does not check schema and already passes row_type (#190) by Keith Lee · 2 weeks ago
  38. b4fad4b feat: KvWriteBatch wiring in Sender (#184) by Keith Lee · 2 weeks ago
  39. da9c112 feat: Introduce Kv table example (#181) by Keith Lee · 2 weeks ago
  40. 1d74c4a feat: Introduce UpsertWriter (#169) by Keith Lee · 2 weeks ago
  41. 350d5a9 feat: support all basic datatypes in compacted key encoder(continuation) (#175) by Anton Borisov · 3 weeks ago
  42. 86c7fe5 feat: introduce KvWriteBatch and PutKvRequest (#176) by yuxia Luo · 3 weeks ago
  43. f4808d8 feat: Introduce KVReadContext and read path wiring (#174) by Anton Borisov · 3 weeks ago
  44. 9c41e2c chore: correct log record batch checksum bounds (#172) by AlexZhao · 3 weeks ago
  45. 18af060 chore: Improve read path error handling logic (#143) by AlexZhao · 3 weeks ago
  46. 60e4c09 feat: Introduce python bindings row-based append API (#142) by Anton Borisov · 3 weeks ago
  47. b1b56a6 feat: introduce lookup support for primary key tables (#159) by Andrea Bozzo · 3 weeks ago
  48. bbd5fad chore: fix read deadlock (#165) by AlexZhao · 3 weeks ago
  49. d203cf9 feat: add column projection support to Python LogScanner (#151) by Anton Borisov · 3 weeks ago
  50. 7dc447d feat: Introduce CompactedRowEncoder (#161) by Keith Lee · 3 weeks ago
  51. eadfa4b chore: Introduce WriteFormat and various small changes to unblock Upsert implementation (#158) by Keith Lee · 3 weeks ago
  52. 49d0c93 feat: introduce KvRecordBatchBuilder (#156) by Anton Borisov · 3 weeks ago
  53. afbe587 chore: add DEVELOPMENT.md (#155) by Keith Lee · 3 weeks ago
  54. 3e3ab5a chore: decrement flushes_in_progress counter in await_flush_comp (#147) by Anton Borisov · 4 weeks ago
  55. dd6183f chore: fix potential deadlock with holding lock during await (#145) by Anton Borisov · 4 weeks ago
  56. dab09b4 chore: implement zero copy in CompactedRowReader (#138) by yuxia Luo · 4 weeks ago
  57. 6be82eb chore: improve datum, use Cow to reduce verbosity and avoid Box::leak gymnastics (#139) by Keith Lee · 4 weeks ago
  58. e01be26 chore: Improve write path error handling logic (#132) by AlexZhao · 4 weeks ago
  59. 4b8c289 chore: fix Box leaking and batch API refactor (#136) by Anton Borisov · 4 weeks ago
  60. 6fc63e4 feat: introduce CompactedRowReader, CompactedRow, CompactedRowDeserializer (#131) by Kelvin Wu · 4 weeks ago
  61. 6962c73 feat: log scanner support poll record batch directly by Anton Borisov · 4 weeks ago
  62. 4b95fc2 feat: introduce CompactedKeyEncoder (#124) by Keith Lee · 4 weeks ago
  63. ff7e869 chore: Fix scanner's example documentation test to allow `cargo test --release` to complete (#129) by Keith Lee · 4 weeks ago
  64. 9873184 chore: fix append hang issue (#126) by AlexZhao · 4 weeks ago
  65. 845c9d7 feat: return error for partitioned tables in FlussConnection#get_table (#115) by Arnav_Panjla · 4 weeks ago
  66. dcdadc4 chore: add license header to fix ci (#123) by yuxia Luo · 5 weeks ago
  67. bddce62 feat: implement CompactedRowWriter (#121) by Kelvin Wu · 5 weeks ago
  68. bb8f26d feat: support bazel build for cpp bindings (#107) by AlexZhao · 5 weeks ago
  69. 670bb5e chore: add integration tests for subscribe_batch and project_by_name (#116) by Andrea Bozzo · 5 weeks ago
  70. 0f43550 chore: rust client to return error when currently unimplemented non-default ZSTD compression is configured (#120) by Keith Lee · 5 weeks ago
  71. 9bc2e9c feat: Introduce HashBucketAssigner (#117) by Keith Lee · 6 weeks ago
  72. db72701 chore: add integration test for list offsets (#52) by Pavlos-Petros Tournaris · 6 weeks ago
  73. f166314 chore: scanner should retry when bucket lead is not available (#102) by Keith Lee · 6 weeks ago
  74. 4ce374a chore: fix bug where column prune won't work when compression is enabled (#108) by Keith Lee · 7 weeks ago
  75. 076cbd6 chore: introduce prefetch to improve log poll performance (#103) by yuxia Luo · 7 weeks ago
  76. 0c8a37f feat: support ListOffset/SubscribeBatch/DropTable for cpp bindings (#100) by AlexZhao · 7 weeks ago
  77. e3728fc chore: optimize get_char method (#105) by yuxia Luo · 7 weeks ago
  78. c883de5 chore: Update the InternalRow Trait: get_binary, get_bytes to return &[u8] (#104) by Kelvin Wu · 7 weeks ago
  79. 4e10d63 chore: Improve error (#77) by yuxia Luo · 7 weeks ago
  80. 49041eb chore: parse_ipc_message should return exception instead of return None if parse failed (#97) by Keith Lee · 7 weeks ago
  81. 24cebe9 feat: support s3 as remote segment (#93) by AlexZhao · 7 weeks ago
  82. 58a842d chore: use log over tracing (#96) by tison · 8 weeks ago
  83. 9054401 chore: upgrade opendal and adopt jiff (#95) by tison · 8 weeks ago
  84. fe72d85 feat: support subscribe from remote (#76) by yuxia Luo · 8 weeks ago
  85. 1503050 chore: abort last not complete batch (#91) by AlexZhao · 8 weeks ago
  86. 92f8c0b chore: update readme to mark it as official rust client (#88) by yuxia Luo · 8 weeks ago
  87. a34f1c1 feat: introduce cpp bindings (#83) by AlexZhao · 8 weeks ago
  88. 3037192 chore: Implement datatype conversion for all types in arrow.rs (#81) by Junbo Wang · 8 weeks ago
  89. c644023 chore: fix GenericRow null detection (#86) by Chase Naples · 8 weeks ago
  90. e9f1cc4 chore: implemented all get methods for GenericRow (#82) by Karan Pradhan · 8 weeks ago
  91. 12d464e feat: Implement JsonSerde for all datatypes (#53) by Pavlos-Petros Tournaris · 9 weeks ago
  92. e4e017c feat: support ColumnPruning (#57) by AlexZhao · 9 weeks ago
  93. e4813e2 chore: fix ci (#69) by yuxia Luo · 10 weeks ago
  94. 0046471 feat: implement Display trait for DataType and related types (#50) by Pavlos-Petros Tournaris · 10 weeks ago
  95. bf95de9 feat: implement get_long for GenericRow (#49) by Yang Guo · 10 weeks ago
  96. 6d9c89f [chore] Fix build fail on mac os (#61) by Evan · 2 months ago
  97. 1d8e4d3 [chore] Add ipc_compression feature to arrow dependency (#59) by Evan · 2 months ago
  98. 6c6687b chore: add integration test for scan records after append (#51) by Pavlos-Petros Tournaris · 2 months ago
  99. 57ac912 [chore] Bump arrow version to 57 (#58) by yuxia Luo · 2 months ago
  100. 86efc93 [feat] Support append arrow record batch (#34) by yuxia Luo · 4 months ago