This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 1e9e8262b146 feat: Support bucket assigning based on record level
index (#17803)
add 12fccee3ef93 feat: align clustering and compaction retry flow for
Flink and Spark (#17839)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/common/util/TableServiceUtils.java | 172 +++++++++++++++++++++
.../hudi/common/util/TestTableServiceUtils.java | 89 +++++++++++
.../sink/clustering/FlinkClusteringConfig.java | 14 ++
.../sink/clustering/HoodieFlinkClusteringJob.java | 67 +++++++-
.../hudi/sink/compact/FlinkCompactionConfig.java | 14 ++
.../hudi/sink/compact/HoodieFlinkCompactor.java | 57 ++++++-
.../apache/hudi/utilities/HoodieClusteringJob.java | 32 ++--
.../org/apache/hudi/utilities/HoodieCompactor.java | 32 +++-
.../deltastreamer/TestHoodieDeltaStreamer.java | 20 ++-
9 files changed, 456 insertions(+), 41 deletions(-)
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/TableServiceUtils.java
create mode 100644
hudi-common/src/test/java/org/apache/hudi/common/util/TestTableServiceUtils.java
