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 bec60f2f6ae [HUDI-9240] Bump spark 35 version to 3.5.5 (#13053)
add 9cd1b610ffe [HUDI-9228] Support rowdata writing for MOR table with
consistent hasing (#13043)
No new revisions were added by this update.
Summary of changes:
.../hudi/client/model/HoodieFlinkRecord.java | 2 +-
.../apache/hudi/configuration/OptionsResolver.java | 3 +-
.../hudi/sink/RowDataStreamWriteFunction.java | 2 +-
.../org/apache/hudi/sink/StreamWriteOperator.java | 2 +-
.../sink/bucket/BucketStreamWriteOperator.java | 18 +++-
...RowDataConsistentBucketStreamWriteFunction.java | 99 ++++++++++++++++++++++
.../FlinkConsistentBucketUpdateStrategy.java | 8 +-
... => RowDataConsistentBucketUpdateStrategy.java} | 89 ++++++++++++-------
.../utils/BucketStreamWriteFunctionWrapper.java | 4 +-
...ConsistentBucketStreamWriteFunctionWrapper.java | 12 ++-
.../sink/utils/StreamWriteFunctionWrapper.java | 4 +-
.../org/apache/hudi/sink/utils/TestWriteBase.java | 2 +-
12 files changed, 195 insertions(+), 50 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/RowDataConsistentBucketStreamWriteFunction.java
copy
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/update/strategy/{FlinkConsistentBucketUpdateStrategy.java
=> RowDataConsistentBucketUpdateStrategy.java} (62%)
