This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 2cb9acc3da [core] Add option to always select level 0 files when
compacting (#5428)
add 9422995a3d [core] Support writing into postpone bucket tables with
table API (#5437)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/paimon/AbstractFileStore.java | 4 +-
.../java/org/apache/paimon/KeyValueFileStore.java | 1 +
.../paimon/operation/AbstractFileStoreWrite.java | 11 +--
.../paimon/operation/KeyValueFileStoreWrite.java | 3 +-
.../paimon/operation/MemoryFileStoreWrite.java | 5 +-
.../postpone/PostponeBucketFileStoreWrite.java | 38 +++++----
.../paimon/table/PrimaryKeyFileStoreTable.java | 15 +++-
...ite.java => PostponeBucketRowKeyExtractor.java} | 27 +++---
.../apache/paimon/utils/FileStorePathFactory.java | 8 +-
.../paimon/table/PrimaryKeySimpleTableTest.java | 11 ++-
.../postpone/PostponeBucketCompactSplitSource.java | 9 +-
.../apache/paimon/flink/sink/FlinkSinkBuilder.java | 6 +-
.../sink/PostponeBucketTableWriteOperator.java | 98 ----------------------
.../paimon/flink/sink/PostponeBucketWriteSink.java | 58 -------------
.../flink/source/TestChangelogDataReadWrite.java | 2 +-
15 files changed, 82 insertions(+), 214 deletions(-)
copy
paimon-core/src/main/java/org/apache/paimon/table/sink/{BatchTableWrite.java =>
PostponeBucketRowKeyExtractor.java} (65%)
delete mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PostponeBucketTableWriteOperator.java
delete mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PostponeBucketWriteSink.java
