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 43c521310733 [HUDI-9543] Fixing null value handling with Secondary
Index (#13605)
add af659920c257 [HUDI-9617] Clean redundant adapters for supporting
multiple Flink versions (#13610)
No new revisions were added by this update.
Summary of changes:
.../hudi/sink/StreamWriteOperatorCoordinator.java | 24 ++++++++---
.../hudi/sink/bulk/sort/SortOperatorGen.java | 4 +-
.../java/org/apache/hudi/sink/v2/HoodieSink.java | 4 +-
.../org/apache/hudi/sink/v2/utils/PipelinesV2.java | 5 +++
.../org/apache/hudi/table/HoodieTableSink.java | 14 +++---
.../apache/hudi/util/DataModificationInfos.java | 12 +++---
.../hudi/adapter/OperatorCoordinatorAdapter.java | 50 ----------------------
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --------------
.../adapter/SupportsPreWriteTopologyAdapter.java} | 11 ++---
.../adapter/SupportsRowLevelDeleteAdapter.java | 42 ------------------
.../adapter/SupportsRowLevelUpdateAdapter.java | 45 -------------------
.../hudi/adapter/OperatorCoordinatorAdapter.java | 50 ----------------------
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --------------
.../adapter/SupportsPreWriteTopologyAdapter.java} | 11 ++---
.../adapter/SupportsRowLevelDeleteAdapter.java | 42 ------------------
.../adapter/SupportsRowLevelUpdateAdapter.java | 45 -------------------
.../hudi/adapter/OperatorCoordinatorAdapter.java | 50 ----------------------
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --------------
.../adapter/SupportsPreWriteTopologyAdapter.java} | 6 +--
.../adapter/SupportsRowLevelDeleteAdapter.java | 42 ------------------
.../adapter/SupportsRowLevelUpdateAdapter.java | 45 -------------------
.../hudi/adapter/OperatorCoordinatorAdapter.java | 50 ----------------------
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --------------
.../adapter/SupportsPreWriteTopologyAdapter.java} | 6 +--
.../adapter/SupportsRowLevelDeleteAdapter.java | 42 ------------------
.../adapter/SupportsRowLevelUpdateAdapter.java | 45 -------------------
.../hudi/adapter/OperatorCoordinatorAdapter.java | 50 ----------------------
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --------------
.../adapter/SupportsPreWriteTopologyAdapter.java} | 6 +--
.../adapter/SupportsRowLevelDeleteAdapter.java | 42 ------------------
.../adapter/SupportsRowLevelUpdateAdapter.java | 45 -------------------
31 files changed, 58 insertions(+), 895 deletions(-)
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
rename
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/{flink/streaming/api/connector/sink2/SupportsPreWriteTopology.java
=> hudi/adapter/SupportsPreWriteTopologyAdapter.java} (77%)
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
rename
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/{flink/streaming/api/connector/sink2/SupportsPreWriteTopology.java
=> hudi/adapter/SupportsPreWriteTopologyAdapter.java} (77%)
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
copy
hudi-flink-datasource/{hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/RichSourceFunctionAdapter.java
=>
hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/SupportsPreWriteTopologyAdapter.java}
(78%)
delete mode 100644
hudi-flink-datasource/hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.20.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.20.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
copy
hudi-flink-datasource/{hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/RichSourceFunctionAdapter.java
=>
hudi-flink1.20.x/src/main/java/org/apache/hudi/adapter/SupportsPreWriteTopologyAdapter.java}
(78%)
delete mode 100644
hudi-flink-datasource/hudi-flink1.20.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.20.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink2.0.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink2.0.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
copy
hudi-flink-datasource/{hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/RichSourceFunctionAdapter.java
=>
hudi-flink2.0.x/src/main/java/org/apache/hudi/adapter/SupportsPreWriteTopologyAdapter.java}
(78%)
delete mode 100644
hudi-flink-datasource/hudi-flink2.0.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink2.0.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
