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%)