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 e905ee9fb6a [HUDI-8901] Fix Timeline Server to process requests from
multiple storage lakes (#12696)
add f5de6628b88 [HUDI-8920] [RFC-84] Optimize SerDe of stream records for
Flink write (excluding bulk insert and append mode) (#12796)
No new revisions were added by this update.
Summary of changes:
.../index/bucket/ConsistentBucketIdentifier.java | 8 +-
.../hudi/client/model/HoodieFlinkInternalRow.java | 135 ++++++++++++++++
.../model/HoodieFlinkInternalRowSerializer.java | 170 +++++++++++++++++++++
.../model/HoodieFlinkInternalRowTypeInfo.java | 104 +++++++++++++
.../org/apache/hudi/sink/StreamWriteFunction.java | 103 ++++++++++---
.../org/apache/hudi/sink/StreamWriteOperator.java | 14 +-
.../hudi/sink/bootstrap/BootstrapOperator.java | 37 +++--
.../bootstrap/batch/BatchBootstrapOperator.java | 13 +-
.../sink/bucket/BucketStreamWriteFunction.java | 45 +++---
.../sink/bucket/BucketStreamWriteOperator.java | 16 +-
.../bucket/ConsistentBucketAssignFunction.java | 23 ++-
.../ConsistentBucketStreamWriteFunction.java | 14 +-
.../sink/partitioner/BucketAssignFunction.java | 81 ++++------
.../sink/transform/RowDataToHoodieFunction.java | 87 ++---------
.../RowDataToHoodieFunctionWithRateLimit.java | 4 +-
.../sink/transform/RowDataToHoodieFunctions.java | 7 +-
.../apache/hudi/sink/utils/PayloadCreation.java | 9 --
.../java/org/apache/hudi/sink/utils/Pipelines.java | 64 +++++---
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 6 +-
.../org/apache/hudi/table/HoodieTableSink.java | 10 +-
.../apache/hudi/sink/ITTestDataStreamWrite.java | 94 +++++++-----
.../hudi/sink/bucket/ITTestBucketStreamWrite.java | 58 ++++---
.../bucket/ITTestConsistentBucketStreamWrite.java | 6 +-
.../utils/BucketStreamWriteFunctionWrapper.java | 16 +-
...ConsistentBucketStreamWriteFunctionWrapper.java | 15 +-
.../sink/utils/StreamWriteFunctionWrapper.java | 25 +--
26 files changed, 783 insertions(+), 381 deletions(-)
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieFlinkInternalRow.java
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieFlinkInternalRowSerializer.java
create mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieFlinkInternalRowTypeInfo.java
