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