You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by da...@apache.org on 2021/11/05 06:37:07 UTC

[hudi] branch master updated (2c1e259 -> f67da0c)

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 2c1e259  [HUDI-2651] Sync all the missing sql options for HoodieFlinkStreamer (#3903)
     add f67da0c  [HUDI-2686] Proccess record after all bootstrap operator ready (#3925)

No new revisions were added by this update.

Summary of changes:
 .../hudi/sink/bootstrap/BootstrapOperator.java     | 29 ++++++++++++-
 .../aggregate/BootstrapAccumulator.java}           | 35 ++++++++-------
 .../bootstrap/aggregate/BootstrapAggFunction.java  | 50 ++++++++++++++++++++++
 .../bootstrap/batch/BatchBootstrapOperator.java    |  4 +-
 4 files changed, 99 insertions(+), 19 deletions(-)
 copy hudi-flink/src/main/java/org/apache/hudi/sink/{event/CommitAckEvent.java => bootstrap/aggregate/BootstrapAccumulator.java} (56%)
 create mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAggFunction.java