This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 362b340415de [HUDI-9703] Support Regex Config in
RunClusteringProcedure (#13761)
add 6b6a8f027b98 [HUDI-9762] Avoid file renaming for Flink COW eager flush
(#13806)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/client/WriteStatus.java | 4 +
.../hudi/io/FileGroupReaderBasedMergeHandle.java | 7 +-
.../apache/hudi/io/HoodieAbstractMergeHandle.java | 16 +-
.../apache/hudi/client/HoodieFlinkWriteClient.java | 9 +-
.../java/org/apache/hudi/io/FlinkCreateHandle.java | 2 +-
...FileGroupReaderBasedIncrementalMergeHandle.java | 93 ++++++
...kFileGroupReaderBasedMergeAndReplaceHandle.java | 217 --------------
.../io/FlinkFileGroupReaderBasedMergeHandle.java | 126 +-------
...ndle.java => FlinkIncrementalConcatHandle.java} | 14 +-
.../hudi/io/FlinkIncrementalMergeHandle.java | 93 ++++++
... FlinkIncrementalMergeHandleWithChangeLog.java} | 12 +-
.../apache/hudi/io/FlinkMergeAndReplaceHandle.java | 222 --------------
.../java/org/apache/hudi/io/FlinkMergeHandle.java | 130 ++------
.../apache/hudi/io/FlinkWriteHandleFactory.java | 10 +-
.../java/org/apache/hudi/io/MergeHandleUtils.java | 48 +++
.../java/org/apache/hudi/util/WriteStatMerger.java | 4 +-
.../org/apache/hudi/util/WriteStatusMerger.java | 68 +++++
.../apache/hudi/util/TestWriteStatusMerger.java | 331 +++++++++++++++++++++
.../java/org/apache/hudi/common/fs/FSUtils.java | 9 +
.../hudi/sink/StreamWriteOperatorCoordinator.java | 8 +
.../apache/hudi/sink/event/WriteMetadataEvent.java | 31 +-
.../sink/TestStreamWriteOperatorCoordinator.java | 19 +-
.../hudi/sink/utils/MockCoordinatorExecutor.java | 1 +
23 files changed, 765 insertions(+), 709 deletions(-)
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkFileGroupReaderBasedIncrementalMergeHandle.java
delete mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkFileGroupReaderBasedMergeAndReplaceHandle.java
rename
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/{FlinkConcatAndReplaceHandle.java
=> FlinkIncrementalConcatHandle.java} (83%)
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkIncrementalMergeHandle.java
rename
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/{FlinkMergeAndReplaceHandleWithChangeLog.java
=> FlinkIncrementalMergeHandleWithChangeLog.java} (88%)
delete mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeAndReplaceHandle.java
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/MergeHandleUtils.java
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatusMerger.java
create mode 100644
hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/util/TestWriteStatusMerger.java
