This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 984f359068 [flink] Support lookup join for Chain Table (#8423)
add 2e81be99f8 [core] enable data-evolution compaction with deletion
vectors rewrite (#8481)
No new revisions were added by this update.
Summary of changes:
.../DataEvolutionCompactCoordinator.java | 11 -
...DataEvolutionCompactDeletionVectorRewriter.java | 247 +++++++++++++++++++++
.../dataevolution/DataEvolutionCompactTask.java | 31 +--
.../apache/paimon/utils/DataEvolutionUtils.java | 17 ++
.../DataEvolutionCompactCoordinatorTest.java | 36 ---
.../table/DataEvolutionDeletionVectorTest.java | 224 ++++++++++++++++++-
...ataEvolutionCompactDeletionVectorOperator.java} | 63 +++---
.../flink/sink/DataEvolutionTableCompactSink.java | 16 ++
.../paimon/spark/procedure/CompactProcedure.java | 4 +
9 files changed, 535 insertions(+), 114 deletions(-)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactDeletionVectorRewriter.java
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/{DataEvolutionCompactionWorkerOperator.java
=> DataEvolutionCompactDeletionVectorOperator.java} (59%)
