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 39fab6d561c [HUDI-9466] Claim RFC 96: Introduce Unified Bucket Index
(#13362)
add 94e4d3763e7 [HUDI-9146][part3] Integrating FileGroup reader into Flink
CDC reader (#13357)
No new revisions were added by this update.
Summary of changes:
...or.java => CloseableConcatenatingIterator.java} | 23 +-
.../hudi/client/utils/ConcatenatingIterator.java | 8 +-
.../org/apache/hudi/config/HoodieWriteConfig.java | 4 +-
.../common/table/read/HoodieFileGroupReader.java | 8 +
.../examples/quickstart/TestQuickstartData.java | 83 -----
.../hudi/sink/bootstrap/BootstrapOperator.java | 74 ++---
.../hudi/sink/clustering/ClusteringOperator.java | 136 +++------
.../table/format/FlinkRowDataReaderContext.java | 10 +-
.../org/apache/hudi/table/format/FormatUtils.java | 162 ++++------
.../hudi/table/format/cdc/CdcInputFormat.java | 127 ++++----
.../table/format/mor/MergeOnReadInputFormat.java | 336 +++------------------
.../org/apache/hudi/util/FlinkWriteClients.java | 21 +-
...erter.java => RecordKeyToRowDataConverter.java} | 24 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 21 --
.../hudi/sink/bucket/ITTestBucketStreamWrite.java | 6 +-
.../bucket/ITTestConsistentBucketStreamWrite.java | 5 +-
.../org/apache/hudi/sink/utils/TestWriteBase.java | 10 +-
.../table/TestHoodieFileGroupReaderOnFlink.java | 37 ++-
.../test/java/org/apache/hudi/utils/TestData.java | 127 +++-----
...r.java => TestRecordKeyToRowDataConverter.java} | 22 +-
20 files changed, 393 insertions(+), 851 deletions(-)
copy
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/{ClosableMergingIterator.java
=> CloseableConcatenatingIterator.java} (57%)
rename
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/{StringToRowDataConverter.java
=> RecordKeyToRowDataConverter.java} (81%)
rename
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/{TestStringToRowDataConverter.java
=> TestRecordKeyToRowDataConverter.java} (84%)
