Google Git
Sign in
apache/paimon/HEAD
  1. 47731c6 [python] Use streaming yield when reading ray data for better performance (#7453) by XiaoHongbo · 7 hours ago master
  2. 040d4d6 [avro] add avro support for vector type (#7449) by ColdL · 19 hours ago
  3. 6a53de8 [core] Refactor vector store related codes (#7447) by Jingsong Lee · 19 hours ago
  4. 14356f9 [python] Add json format for CLI table read and list-partitions (#7452) by Jingsong Lee · 19 hours ago
  5. 224c998 [core] Refine btree index entry scanning API (#7450) by YeJunHao · 20 hours ago
  6. 0816a27 [python] Introduce branch_manager API for pypaimon (#7448) by xuzifu666 · 22 hours ago
  7. e92b27a [core] Introduce vector-store for data-evolution table (#7240) by ColdL · 25 hours ago
  8. 79f70ea [core] Do not delete manifest files on false commit result (#7441) by YeJunHao · 25 hours ago
  9. cbfa0f4 [Flink] Fix SystemTableSource unordered flag for bucket-unaware system talbes (#7434) by sanshi · 26 hours ago
  10. 81760b0 [python] Add list partitions support for Python CLI (#7442) by Jingsong Lee · 26 hours ago
  11. 2ca3a57 [core] Add partition format check if partition expire time is set (#7428) by tsreaper · 28 hours ago
  12. d223650 [core] flink support vector index create (#7437) by jerry · 28 hours ago
  13. e2addc7 [python] Add acceptance test to lint-python (#7439) by Jingsong Lee · 28 hours ago
  14. 2807a22 [spark] Fix concurrent V2 MERGE INTO data inconsistency (#7432) by Kerwin Zhang · 32 hours ago
  15. 61db454 [python] Add IncrementalDiff acceptance tests and streaming API docs (#7436) by Toby Cole · 32 hours ago
  16. d7c7163 [python] Add consumer ID support for streaming read progress persistence (#7435) by Toby Cole · 2 days ago
  17. 677a8d6 [python] Fix wrong file extension parsing for compressed json/csv files (#7433) by XiaoHongbo · 2 days ago
  18. bcfbf65 Bump org.apache.flink:flink-connector-mysql-cdc from 3.1.1 to 3.5.0 in /paimon-e2e-tests (#7430) by dependabot[bot] · 2 days ago
  19. 410e126 [vector] support lumina vector index (#7330) by jerry · 2 days ago
  20. 2b1623a [core] Add table properties sync to JDBC catalog (#7423) by Nick Del Nano · 2 days ago
  21. 8db3655 [python] Fix _apply_push_down_limit not considering non-raw-convertible splits issue (#7427) by XiaoHongbo · 2 days ago
  22. e076346 [rest] Add IO cache configuration option to token (#7425) by Zouxxyy · 3 days ago
  23. e63d9ab [python] Add AsyncStreamingTableScan and StreamReadBuilder for continuous streaming reads (#7424) by Toby Cole · 4 days ago
  24. 28544bb [test] Add className to unstable MergeInto tests by JingsongLi · 5 days ago
  25. c466690 [test] Fix unstable test in BitSliceIndexRoaringBitmapTest by JingsongLi · 5 days ago
  26. d91ff26 [python] Add SnapshotManager batch lookahead with get_snapshots_batch and find_next_scannable (#7418) by Toby Cole · 5 days ago
  27. ba79e42 [core] Enable incrementalScan for BTreeGlobalIndexBuilder (#7416) by YeJunHao · 5 days ago
  28. 56a345b [python] Add ChangelogProducer enum and changelog-producer config option (#7417) by Toby Cole · 5 days ago
  29. 0d3cab4 [python] Improve the consumer_manager API and support in file_store_table (#7415) by xuzifu666 · 6 days ago
  30. 85eb1ef [flink] supports dynamic options for system table (#7414) by Faiz · 6 days ago
  31. 949b9f5 [core] Add Compaction Sort Buffer metrics (#7411) by Mike Dias · 6 days ago
  32. e2aec56 [flink] fix blob type conversion (#7405) by Faiz · 6 days ago
  33. 16915c5 [python] Support getting snapshot by RESTCatalog (#7412) by umi · 6 days ago
  34. 99e1089 [core] Supoort Option of adding columns before partition (#7374) by umi · 6 days ago
  35. c42cb99 [test] Add random name to MergeIntoTableTestBase by JingsongLi · 6 days ago
  36. 1d5c4eb [flink] Enable BTreeIndexTopoBuilder to build multiple columns index in one job (#7413) by YeJunHao · 6 days ago
  37. b110f6e [core] Introduce SimpleLsmKvDb to put and get based on Paimon SST (#7407) by Jingsong Lee · 6 days ago
  38. 2417b38 [core] Abstract KvCompactionManagerFactory in KeyValueFileStoreWrite (#7403) by Jingsong Lee · 6 days ago
  39. 5407b88 [python] Add consumer management for streaming progress (#7349) by Toby Cole · 6 days ago
  40. 75e0e4e [python] Add row kind support for TableRead (#7394) by Toby Cole · 7 days ago
  41. 466e6ef [python] Make sure primary key not null in schema (#7406) by XiaoHongbo · 7 days ago
  42. 5749eaf [flink] StoreMultiCommitter support dynamic options per table (#7404) by yuzelin · 7 days ago
  43. 79b5dfb [core] Use snapshots in ExpireSnapshotsImpl (#7401) by Jingsong Lee · 7 days ago
  44. 0f48a5a [python] file_scanner should use with_shard instead of new interfaces by JingsongLi · 7 days ago
  45. 4a884fc [python] Add FollowUpScanner, IncrementalDiffScanner, sharding (#7348) by Toby Cole · 7 days ago
  46. 7a9a0da [python] Implement Python ObjectTable with read support (#7400) by shyjsarah · 7 days ago
  47. 6772bcd [core] Optimize snapshots collect in ExpireSnapshots (#7397) by Jingsong Lee · 7 days ago
  48. 3274d79 [core] Introduce hive bucket function to align with spark hive bucket (#7393) by WenjunMin · 7 days ago
  49. 063be6f [flink] Implement FLIP-314 LineageVertexProvider for source and sink connectors (#7311) by jsingh-yelp · 7 days ago
  50. e0dc2d8 [flink] Migrate paimon-flink-cdc from KafkaDeserializationSchema to KafkaRecordDeserializationSchema (#7396) by Umesh Dangat · 7 days ago
  51. 18a7701 [flink] [spark] Fix btree procedure GlobalIndexMeta row range not accurate (#7354) by YeJunHao · 8 days ago
  52. 44f7061 [python] Fix wrong result when using where and limit in CLI table read (#7391) by Jingsong Lee · 8 days ago
  53. b7d1af0 [doc] Fix ref error in data-types by JingsongLi · 8 days ago
  54. d227603 [python] Introduce where for Python CLI table read (#7389) by Jingsong Lee · 8 days ago
  55. 12e1b60 [python] Fix blob table read failure when filtering by _ROW_ID (#7390) by XiaoHongbo · 8 days ago
  56. bc41e71 [test] fix unstable test for weighted external-path (#7387) by LsomeYeah · 8 days ago
  57. 5a54d6a [core] Support options in ObjectTable (#7378) by shyjsarah · 8 days ago
  58. 3c9fe28 [core] Fix chain table partition listing under data filters. (#7268) by Junrui Lee · 8 days ago
  59. 87a4c91 [python] Backtick quoting for identifiers, exists_batch optimization (#7347) by Toby Cole · 8 days ago
  60. 8c765c5 [core] upgrade lz4-java to 1.10.4 due to CVE (#7384) by Pei Yu · 8 days ago
  61. e819107 [core] upgrade snappy-java to 1.1.10.8 due to CVE (#7383) by Pei Yu · 8 days ago
  62. 04a73e0 [core] Support partition range predicate pushdown for FilesTable (#7376) by Kerwin Zhang · 8 days ago
  63. 13e5564 [spark] Optimize drop multi partitions in batch (#7380) by WenjunMin · 8 days ago
  64. 14fb379 [core] Validate the deletion vector is disabled for chain table (#7382) by WenjunMin · 8 days ago
  65. 339e8c6 [core] upgrade aircompresssor to 2.0.3 due to CVE (#7375) by PJ Fanning · 9 days ago
  66. a164e70 [spark] Fix table name conflict in concurrent MergeInto tests (#7381) by Kerwin Zhang · 9 days ago
  67. c9cf264 [python] Introduce select for CLI table read (#7377) by Jingsong Lee · 9 days ago
  68. b160e8c [python] Correct pyroaring version in requirements by JingsongLi · 9 days ago
  69. 2a1406d [test] Enrich table name in MergeIntoTableTestBase by JingsongLi · 9 days ago
  70. 0916af4 [test] Fix unstable test: FileStoreLookupFunctionTest.testLookupScanLeak by JingsongLi · 9 days ago
  71. f4383d1 [python] Remove useless parameters in blob_writer.py by JingsongLi · 9 days ago
  72. dd27fcd [rest] Introduce reset consumer api in rest (#7372) by xuzifu666 · 9 days ago
  73. 44a8004 [python] Introduce Python CLI table snapshot (#7373) by Jingsong Lee · 9 days ago
  74. 41bb246 [python] Fix time mapping by always using time32 (#7371) by XiaoHongbo · 9 days ago
  75. 5e0859d [python] Introduce catalog list-dbs in Python CLI (#7366) by Jingsong Lee · 9 days ago
  76. e3b02b0 [hotfix][docs] replace the documentation URL for data-types blob (#7370) by yangjf2019 · 9 days ago
  77. bafbfd6 [python] Add i short name to ignore-if-not-exists for database by JingsongLi · 10 days ago
  78. d707b1c [python] Support dynamic bucket write (#7363) by XiaoHongbo · 10 days ago
  79. 8176dde [python] Introduce database related commands to Python CLI (#7362) by Jingsong Lee · 10 days ago
  80. 5f5986d [python] Introduce table import, drop and alter to Python CLI (#7360) by Jingsong Lee · 10 days ago
  81. 4a446eb [python] Fix py version required in README (#7361) by XiaoHongbo · 10 days ago
  82. 0c22e07 [test] Add missing LeafFunction coverage in PredicateJsonSerdeTest (#7359) by Jiajia Li · 10 days ago
  83. 30afdb3 [python] support predicate NotBetween, Like function (#7352) by Jiajia Li · 10 days ago
  84. 949cb4f [python] Introduce Paimon CLI in PyPaimon (#7358) by Jingsong Lee · 10 days ago
  85. 798bec8 [doc] Document ignoreIfExists for create_branch by JingsongLi · 11 days ago
  86. 85b8dee [core] Add IF NOT EXISTS support for create_branch operation (#7353) by Rhett CfZhuang · 11 days ago
  87. 30bd692 [python] Remove oss and pylance from requirements deps by JingsongLi · 11 days ago
  88. 965412b [hive] Lazily initialize HMS client pool in HiveCatalog (#7346) by WenjunMin · 11 days ago
  89. 9f97165 [core] introduce weighted strategy for external-path (#7356) by LsomeYeah · 11 days ago
  90. f84674b [common] Fix possible deadlock in ParallelExecution (#7355) by tsreaper · 11 days ago
  91. ca6a8db [doc] Add rename_tag for python doc (#7345) by xuzifu666 · 13 days ago
  92. 259a143 [cdc] Add metadata column support for Kafka CDC connector (#7315) by Nick Del Nano · 13 days ago
  93. cac3980 [rest] Introduce consumers api definition in rest (#7339) by xuzifu666 · 13 days ago
  94. da3ffd0 [doc] Fix typos in docs and code comments (#7341) by Jiajia Li · 13 days ago
  95. c846333 [core] Introduce Catalog.listPartitionsByNames (#7340) by Jingsong Lee · 14 days ago
  96. 188ce21 [filesystem] support report access extended information to DLF OSS (#7337) by shyjsarah · 14 days ago
  97. e102abd [flink] optimize flink Data-Evolution-Merge-Into (#7324) by Faiz · 2 weeks ago
  98. be4d1a3 [python] Support conflict detection when updating existing data concurrently. (#7323) by umi · 2 weeks ago
  99. 4cac917 [core] Refactor BlobFileContext for blob writing by JingsongLi · 2 weeks ago
  100. 2c7bb26 [core] Support external-storage BLOB columns and MERGE INTO updates for descriptor-based BLOB columns (#7328) by Junrui Lee · 2 weeks ago