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

Posted to commits@hudi.apache.org by ga...@apache.org on 2021/06/06 02:40:34 UTC

[hudi] branch master updated (2a7e1e0 -> 08464a6)

This is an automated email from the ASF dual-hosted git repository.

garyli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from 2a7e1e0  [HUDI-1942] Add Default value for HIVE_AUTO_CREATE_DATABASE_OPT_KEY in HoodieSparkSqlWriter (#3036)
     add 08464a6  [HUDI-1931] BucketAssignFunction use ValueState instead of MapState (#3026)

No new revisions were added by this update.

Summary of changes:
 .../sink/partitioner/BucketAssignFunction.java     | 56 +++++++++++----------
 .../sink/partitioner/BucketAssignOperator.java     | 57 ++++++++++++++++++++++
 .../org/apache/hudi/table/HoodieTableSink.java     |  3 +-
 .../org/apache/hudi/sink/StreamWriteITCase.java    |  5 +-
 .../hudi/sink/utils/CompactFunctionWrapper.java    | 10 ++--
 .../hudi/sink/utils/MockOperatorStateStore.java    |  6 ++-
 .../org/apache/hudi/sink/utils/MockValueState.java | 28 ++++++-----
 .../sink/utils/StreamWriteFunctionWrapper.java     | 33 ++++++++++++-
 8 files changed, 147 insertions(+), 51 deletions(-)
 create mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignOperator.java
 copy hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/InMemoryMetricsReporter.java => hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockValueState.java (66%)