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 2022/03/02 07:16:07 UTC

[hudi] branch master updated (85f47b5 -> 10d866f)

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 85f47b5  [HUDI-3469] Refactor `HoodieTestDataGenerator` to provide for reproducible Builds (#4866)
     add 10d866f  [HUDI-3315] RFC-35 Part-1 Support bucket index in Flink writer (#4679)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/hudi/index/HoodieIndex.java    |   2 +-
 .../apache/hudi/index/bucket/BucketIdentifier.java |  12 ++
 .../java/org/apache/hudi/table/HoodieTable.java    |   4 +
 .../apache/hudi/configuration/FlinkOptions.java    |  22 +++
 .../apache/hudi/configuration/OptionsResolver.java |   5 +
 .../hudi/sink/BucketStreamWriteFunction.java       | 158 +++++++++++++++++++++
 ...perator.java => BucketStreamWriteOperator.java} |  17 +--
 .../org/apache/hudi/sink/StreamWriteFunction.java  |   2 +-
 .../sink/partitioner/BucketIndexPartitioner.java}  |  31 ++--
 .../java/org/apache/hudi/sink/utils/Pipelines.java |  25 +++-
 .../org/apache/hudi/table/HoodieTableFactory.java  |   6 +
 .../org/apache/hudi/table/HoodieTableSink.java     |   1 -
 .../org/apache/hudi/sink/StreamWriteITCase.java    |  10 +-
 .../apache/hudi/table/TestHoodieTableFactory.java  |  11 ++
 14 files changed, 265 insertions(+), 41 deletions(-)
 create mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/BucketStreamWriteFunction.java
 copy hudi-flink/src/main/java/org/apache/hudi/sink/{StreamWriteOperator.java => BucketStreamWriteOperator.java} (73%)
 copy hudi-flink/src/{test/java/org/apache/hudi/sink/utils/MockValueState.java => main/java/org/apache/hudi/sink/partitioner/BucketIndexPartitioner.java} (54%)