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