This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 6b7157536d [MINOR] fix indent to make build pass (#6721)
add e8c26c5639 [HUDI-3478] Implement CDC Write in Spark (#6697)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/io/HoodieAppendHandle.java | 18 --
.../java/org/apache/hudi/io/HoodieCDCLogger.java | 253 +++++++++++++++++++++
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 39 +++-
.../apache/hudi/io/HoodieSortedMergeHandle.java | 23 +-
.../java/org/apache/hudi/io/HoodieWriteHandle.java | 36 +++
.../hudi/table/action/clean/CleanPlanner.java | 35 ++-
.../java/org/apache/hudi/common/fs/FSUtils.java | 2 +-
.../apache/hudi/common/model/HoodieWriteStat.java | 28 +++
.../hudi/common/table/HoodieTableConfig.java | 25 ++
.../hudi/common/table/HoodieTableMetaClient.java | 24 ++
.../hudi/common/table/cdc/HoodieCDCOperation.java | 35 ++-
.../cdc/HoodieCDCSupplementalLoggingMode.java | 35 ++-
.../hudi/common/table/cdc/HoodieCDCUtils.java | 150 ++++++++++++
.../hudi/common/table/log/HoodieLogFileReader.java | 4 +
.../table/log/HoodieMergedLogRecordScanner.java | 6 +-
...ieCorruptBlock.java => HoodieCDCDataBlock.java} | 43 ++--
.../common/table/log/block/HoodieLogBlock.java | 3 +-
.../hudi/metadata/HoodieTableMetadataUtil.java | 4 +
.../common/functional/TestHoodieLogFormat.java | 81 ++++++-
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 6 +-
20 files changed, 760 insertions(+), 90 deletions(-)
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCDCLogger.java
copy
hudi-utilities/src/test/java/org/apache/hudi/utilities/DummySchemaPostProcessor.java
=>
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCOperation.java
(59%)
copy
hudi-utilities/src/test/java/org/apache/hudi/utilities/DummySchemaPostProcessor.java
=>
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCSupplementalLoggingMode.java
(53%)
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCUtils.java
copy
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/{HoodieCorruptBlock.java
=> HoodieCDCDataBlock.java} (52%)
