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 22c739f347bd [MINOR] Update RFC index with RFC-99 and RFC-100 (#13750)
add ec309f984f56 [HUDI-9727] Migrate merge handle to
FileGroupReaderBasedMergeHandle for Flink COW write (#13734)
No new revisions were added by this update.
Summary of changes:
.../hudi/io/FileGroupReaderBasedMergeHandle.java | 46 +++++--
.../hudi/client/model/HoodieFlinkRecord.java | 12 --
.../model/PartialUpdateFlinkRecordMerger.java | 2 +-
...FileGroupReaderBasedMergeAndReplaceHandle.java} | 49 +++----
...a => FlinkFileGroupReaderBasedMergeHandle.java} | 41 +++---
.../apache/hudi/io/FlinkWriteHandleFactory.java | 41 ++++--
.../hudi/BaseSparkInternalRecordContext.java | 5 +
.../TestBaseSparkInternalRowReaderContext.java | 9 ++
.../org/apache/hudi/avro/AvroRecordContext.java | 10 ++
.../apache/hudi/common/engine/RecordContext.java | 9 ++
.../hudi/common/table/HoodieTableConfig.java | 2 +-
.../table/read/BufferedRecordMergerFactory.java | 43 +++---
.../common/table/read/PartialUpdateHandler.java | 153 ++++++++++++---------
.../hudi/avro/TestHoodieAvroReaderContext.java | 11 ++
.../common/table/read/SchemaHandlerTestBase.java | 5 +
.../org/apache/hudi/sink/StreamWriteFunction.java | 9 +-
.../hudi/table/format/FlinkRecordContext.java | 5 +
.../table/format/FlinkRowDataReaderContext.java | 4 +
.../hudi/table/format/cdc/CdcInputFormat.java | 4 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 32 ++---
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 10 +-
.../format/TestFlinkRowDataReaderContext.java | 9 ++
.../apache/hudi/table/format/TestInputFormat.java | 34 ++++-
.../apache/hudi/utils/TestFlinkWriteClients.java | 10 ++
.../org/apache/hudi/utils/TestStreamerUtil.java | 50 +++++++
.../org/apache/hudi/hadoop/HiveRecordContext.java | 5 +
.../hudi/hadoop/TestHiveHoodieReaderContext.java | 16 +++
.../hudi/functional/TestBufferedRecordMerger.java | 5 +
28 files changed, 433 insertions(+), 198 deletions(-)
copy
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/{FlinkMergeAndReplaceHandle.java
=> FlinkFileGroupReaderBasedMergeAndReplaceHandle.java} (80%)
copy
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/{FlinkMergeHandle.java
=> FlinkFileGroupReaderBasedMergeHandle.java} (85%)
