You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by zh...@apache.org on 2025/01/14 10:24:01 UTC
(hudi) branch incremental-TableService updated (8132af0ed34 -> 2a3cc5e3791)
This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 pushed a change to branch incremental-TableService
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 8132af0ed34 fix ut
add 2dbefd3c045 code review
add 2a3cc5e3791 code review and need more compaction test
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/config/HoodieWriteConfig.java | 4 +-
.../action/BaseTableServicePlanActionExecutor.java | 79 ++++++++----
.../action/IncrementalPartitionAwareStrategy.java | 14 +-
.../cluster/ClusteringPlanPartitionFilter.java | 24 ++--
.../PartitionAwareClusteringPlanStrategy.java | 15 +--
.../strategy/BoundedIOCompactionStrategy.java | 20 ++-
.../BoundedPartitionAwareCompactionStrategy.java | 41 +++---
.../compact/strategy/CompactionStrategy.java | 21 +--
.../strategy/CompositeCompactionStrategy.java | 14 +-
.../strategy/DayBasedCompactionStrategy.java | 14 +-
.../LogFileNumBasedCompactionStrategy.java | 29 +++--
.../LogFileSizeBasedCompactionStrategy.java | 37 ++++--
.../PartitionRegexBasedCompactionStrategy.java | 4 +-
.../strategy/UnBoundedCompactionStrategy.java | 9 +-
.../UnBoundedPartitionAwareCompactionStrategy.java | 15 ++-
.../TestBaseTableServicePlanActionExecutor.java | 4 +-
...xecutor.java => TestIncrementalClustering.java} | 2 +-
.../action/compact/TestIncrementalCompaction.java | 54 ++++++++
.../strategy/TestHoodieCompactionStrategy.java | 142 +++++++++++++++------
19 files changed, 362 insertions(+), 180 deletions(-)
rename hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/{TestClusteringPlanActionExecutor.java => TestIncrementalClustering.java} (99%)
create mode 100644 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/TestIncrementalCompaction.java