Google Git
Sign in
apache / paimon / HEAD
  1. bce56bf [test] Fix unstable test: handle MiniCluster shutdown gracefully in collect method (#6913) by Shekhar Prasad Rajak · 3 hours ago master
  2. 9661f05 [python] fix ray dataset not lazy loading issue when parallelism = 1 (#6916) by XiaoHongbo · 3 hours ago
  3. e6c1ad7 [core] Refactor ExternalPathProviders abstraction by JingsongLi · 7 hours ago
  4. 55e4d28 [spark] fix Merge Into unstable tests (#6912) by Weitai Li · 7 hours ago
  5. f15bcfe [core] Enable Entropy Inject for data file path to prevent being throttled by object storage (#6832) by JennyChen · 7 hours ago
  6. 44b14ee [iceberg] support millisecond timestamps in iceberg compatibility mode (#6352) by Max Falk · 15 hours ago
  7. 09ad28d [spark] Handle NPE for pushdown aggregate when a datasplit has a null max/min value (#6611) by xieshuaihu · 15 hours ago
  8. 2eba6b9 [test] Fix unstable case testLimitPushDown by JingsongLi · 28 hours ago
  9. fc86abe [core] Refactor row id pushdown to DataEvolutionFileStoreScan by JingsongLi · 31 hours ago
  10. b6d2302 [spark] paimon-spark supports row id push down (#6697) by Xiao Zhu · 29 hours ago
  11. f5e5ada [spark] Support compact_database procedure (#6328) (#6910) by userzhy · 2 days ago
  12. 61d7443 [lucene] Fix row count in IndexManifestEntry by JingsongLi · 2 days ago
  13. 8b7c13a [test] Remove unstable test: AppendTableITCase.testFlinkMemoryPool by JingsongLi · 2 days ago
  14. 732f4ee [core] Refactor Global index writer and reader for Btree by JingsongLi · 2 days ago
  15. 1523ecb [core] Minor refactor to magic number into footer by JingsongLi · 2 days ago
  16. 7dd7fa0 [core] Support btree global index in paimon-common (#6869) by Faiz · 2 days ago
  17. 1179722 [spark] Optimize compact for data-evolution table, commit multiple times to avoid out of memory (#6907) by YeJunHao · 2 days ago
  18. e84b7b4 [rest] Add fromSnapshot to rollback (#6905) by Jingsong Lee · 2 days ago
  19. 3daff8f [test] Fix unstable RowTrackingTestBase test by JingsongLi · 2 days ago
  20. 0a4603a [core] Simplify FileStoreCommitImpl to extract some classes (#6904) by Jingsong Lee · 2 days ago
  21. 5ce14f6 [core] fix image desc in the chain table doc (#6903) by Stefanietry · 3 days ago
  22. a0ba670 [refactor] Make subclass of FallbackSplit public (#6901) by yuzelin · 3 days ago
  23. 08aeb86 [test] Disable unstable test: BitSliceIndexRoaringBitmapTest.testCompareUsingMinMax by JingsongLi · 3 days ago
  24. c777456 [core] fix in predict when value is empty (#6900) by Stefanietry · 3 days ago
  25. ebad722 [test] Fix unstable test StoreMultiCommitterTest.testCheckpointAbort by JingsongLi · 3 days ago
  26. 471c0be [test] Remove unstable cdc tests in e2e by JingsongLi · 3 days ago
  27. 06cfebc [Core] Correct identifer information in catalog enviroment when using switch branch (#6898) by Stefanietry · 3 days ago
  28. 5db324d [core] Remove useless close in SstFileWriter by JingsongLi · 3 days ago
  29. e34762d [core] Refactor footer of lookup sst file to SortLookupStoreFooter by JingsongLi · 3 days ago
  30. adcdb7b [doc] Add options supported by the python API by umi · 4 weeks ago
  31. 82cac0e [cdc] support remained postgres cdc source options excluding chunkKeyColumns (#6888) by SeungMin · 3 days ago
  32. 64481a1 [cdc] Support more mysql cdc source options (#6886) by SeungMin · 3 days ago
  33. a420f9f [core] No consumer expiration when write-only is true (#6890) by yuzelin · 3 days ago
  34. a3a336e [docs] add api docs for c++ paimon (#6881) by Yonghao Fang · 3 days ago
  35. ee33ba9 [doc] Add VARIANT type in data-types by JingsongLi · 3 days ago
  36. b1e074b [test] add --add-opens for sun.security.krb5 to silence reflective-access warning (#6895) by Jiajia Li · 3 days ago
  37. 6b1b92c [python] Relax overly strict dependency pins in paimon-python requirements (#6893) by userzhy · 3 days ago
  38. f45c6f2 [docs] Add missing executeFilter() call in Java API read examples (#6892) by userzhy · 4 days ago
  39. abc3a84 [flink] Enable data-evolution compaction on flink (#6875) by YeJunHao · 4 days ago
  40. fd8b159 [spark] Remove useless Factories for bitmap and lucene by JingsongLi · 4 days ago
  41. d4c3ba2 [spark] spark: lucene vector index write (#6876) by jerry · 4 days ago
  42. 6f46484 [core] Support enable and disable tag time expiration (#6884) by yuzelin · 4 days ago
  43. aa1eb04 [doc] Fix weight for Chain table by JingsongLi · 4 days ago
  44. ebb3a71 [core] Remove useless cast in ChainGroupReadTable by JingsongLi · 4 days ago
  45. a7a741d [core] Introduce FallbackSplit in FallbackReadFileStoreTable by JingsongLi · 4 days ago
  46. a9df02e [core] Support chain tbl on batch mode (#6394) by Stefanietry · 4 days ago
  47. 184b95a [format] csv: optimize parsing of short, byte, int and long (#6856) by jerry · 4 days ago
  48. ad757d2 [spark] support 'SHOW VIEWS FROM' syntax (#6873) by Yann Byron · 4 days ago
  49. 4c31fbb [format] Introduce text format table (#6879) by Zouxxyy · 4 days ago
  50. c38eede [core][flink] Compact action support read high level files from overwrite upgrade (#6868) by yuzelin · 5 days ago
  51. 816a76f [spark] Allow format table and spark table options to recognize each other by Zouxxyy · 5 days ago
  52. 6b18fc3 [hotfix] fix check stype fail (#6874) by jerry · 5 days ago
  53. 005061a [python] rename drop_database/drop_table ignore_if_exists flag to ignore_if_not_exists (#6846) by Jiajia Li · 5 days ago
  54. bc942cd [python] Refactor update by row id to TableUpdate by JingsongLi · 5 days ago
  55. 6fe570b [python] introduce update_columns in python api. (#6861) by zhoulii · 5 days ago
  56. 5924728 [arrow] Introduce Arrow native read & write interface (#6855) by yuzelin · 5 days ago
  57. ee095bc [core] Refactor VectorSearch to keep required fields by JingsongLi · 5 days ago
  58. 3d41be6 [vector] support vector search (#6807) by jerry · 5 days ago
  59. 21f6a44 [core] Optimize calculate for DataEvolutionCompactCoordinator (#6867) by YeJunHao · 5 days ago
  60. 78f99e4 [test] Add test of compact conflict with overwrite upgrade (#6864) by yuzelin · 5 days ago
  61. 88e2aa2 [core] Fix data evolution mode with limit manifest push down by JingsongLi · 6 days ago
  62. f95454b [core] optimize read append table with limit (#6848) by wangwj · 6 days ago
  63. e3e3320 [test] Fix unstable Data Evolution test by JingsongLi · 6 days ago
  64. 0440d76 Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 (#6845) by dependabot[bot] · 6 days ago
  65. dccbb57 [core] SstFileReader supports range query (#6842) by Faiz · 6 days ago
  66. 708dec8 [hotfix] Remove useless roadmap by JingsongLi · 6 days ago
  67. c869d90 [core] Refactor Index Reader in BlockReader (#6865) by Jingsong Lee · 6 days ago
  68. b9ccee6 [python] Support read blob row by offsets in with_shard feature (#6863) by umi · 6 days ago
  69. c222436 [docs] Fixing documentation about lookup change log producers (#6860) by junmuz · 6 days ago
  70. 8c41658 [flink] Fix that action/procedure cannot remove unexisting files from manifests when dv enabled. (#6854) by zhoulii · 7 days ago
  71. 4fe9e1f [spark] Fix SparkCatalog converts catalog option keys to lower case (#6708) by zhan7236 · 7 days ago
  72. 2f59458 [spark] Adding support for Iceberg compatibility options to be passed as table properties with dataframe APIs (#6803) by junmuz · 7 days ago
  73. 3acf89b [spark] Refactor metadata only delete (#6852) by Zouxxyy · 7 days ago
  74. 7d86289 [spark] Refactor spark v2 DELETE (#6851) by Zouxxyy · 7 days ago
  75. fde14ef [core] Minor refactor the maintenance order in TableCommitImpl (#6830) by yuzelin · 9 days ago
  76. 3516314 [spark] Enable data-evolution table compact (#6839) by YeJunHao · 9 days ago
  77. 874d414 [spark] Introduce source.split.target-size-with-column-pruning (#6837) by Zouxxyy · 9 days ago
  78. f23f6b7 [test] Fix failed test testWriteFixedBucketWithDifferentBucketNumber (#6843) by yuzelin · 9 days ago
  79. 67821d8 [python] Refactor read and write options (#6808) by umi · 9 days ago
  80. 4584885 [spark] Optimize MERGE INTO self-merge updates on dataEvolution table (#6827) by Weitai Li · 9 days ago
  81. 8dbe45b [test] Add test for overwrite-upgrade (#6841) by yuzelin · 9 days ago
  82. bc1d009 [python] Make the overwrite parameter of the write_file API take effect. (#6840) by Jiajia Li · 9 days ago
  83. 2d337b8 [hotfix] Update docs for overwrite-upgrade by JingsongLi · 9 days ago
  84. f817587 [core] Overwrite upgrade should be implemented in FileStoreCommitImpl by JingsongLi · 9 days ago
  85. 0bc3294 [core][flink] Support upgrade the data files when overwriting pk table with dv and write-only (#6815) by yuzelin · 10 days ago
  86. 1055e4b [core] Refactor scan and plan in DataEvolutionCompactCoordinator by JingsongLi · 10 days ago
  87. 072127d [core] Introducer compaction for data-evolution table (#6828) by YeJunHao · 10 days ago
  88. fb10527 [hive] Preserve default partition name when copying Hive tables (#6829) by Zouxxyy · 10 days ago
  89. b8c3932 [spark] Refactor BaseScan and PaimonStatistics (#6833) by Zouxxyy · 10 days ago
  90. 90a3351 [core] change range strategy of clustering to 'SIZE' (#6826) by LsomeYeah · 11 days ago
  91. a93be1f [core] Remove useless KeyValueFileReaderFactoryType by JingsongLi · 11 days ago
  92. a133f7d [core] Refactor ChainSplit to remove bucket and totalBucket by JingsongLi · 11 days ago
  93. 5e2d3c1 [core] Support chain split and read (#6801) by Stefanietry · 11 days ago
  94. bbf1c9a [spark] Add read batch time metric (#6798) by Zouxxyy · 11 days ago
  95. 6bb6f49 [spark] Support DELETE on Paimon append-only table in spark V2 write (#6704) by Kerwin Zhang · 12 days ago
  96. 1cc7cf2 [flink] support detecting fields changes for dedicated compaction in streaming mode (#6690) by LsomeYeah · 12 days ago
  97. 57ef2c9 [doc] fix typos in fileindex, manifest, and rest-catalog related docs (#6824) by Jiajia Li · 12 days ago
  98. e62ff31 [core] fix the wrong parsing for map type with string sub type (#6790) by Yann Byron · 12 days ago
  99. f802974 [spark] Add custom topology builder for global index builder (#6823) by YeJunHao · 12 days ago
  100. 8cebe06 [core] Refactor name of GlobalIndexReader classes by JingsongLi · 12 days ago