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 c7c517f [HUDI-2340] Merge the data set for flink bounded source when
changelog mode turns off (#3513)
add ab3fbb8 [HUDI-2342] Optimize Bootstrap operator (#3516)
No new revisions were added by this update.
Summary of changes:
...otstrapFunction.java => BootstrapOperator.java} | 138 +++++++++++----------
.../bootstrap/aggregate/BootstrapAccumulator.java | 53 --------
.../bootstrap/aggregate/BootstrapAggFunction.java | 50 --------
...apFunction.java => BatchBootstrapOperator.java} | 30 ++---
.../java/org/apache/hudi/sink/utils/Pipelines.java | 10 +-
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 6 +-
.../org/apache/hudi/sink/StreamWriteITCase.java | 6 +-
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 4 +-
.../apache/hudi/sink/utils/CollectorOutput.java | 78 ++++++++++++
.../hudi/sink/utils/CompactFunctionWrapper.java | 2 -
...xt.java => MockStateInitializationContext.java} | 17 ++-
.../sink/utils/StreamWriteFunctionWrapper.java | 76 +++++++-----
12 files changed, 237 insertions(+), 233 deletions(-)
rename
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/{BootstrapFunction.java
=> BootstrapOperator.java} (63%)
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAccumulator.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAggFunction.java
rename
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/batch/{BatchBootstrapFunction.java
=> BatchBootstrapOperator.java} (73%)
create mode 100644
hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
rename
hudi-flink/src/test/java/org/apache/hudi/sink/utils/{MockFunctionInitializationContext.java
=> MockStateInitializationContext.java} (71%)
