This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 0284cde [HUDI-1876] wiring in Hadoop Conf with AvroSchemaConverters
instantiation (#2914)
add 0a58639 [HUDI-1821] Remove legacy code for Flink writer (#2868)
No new revisions were added by this update.
Summary of changes:
.../exception/HoodieFlinkStreamerException.java | 30 ---
.../main/java/org/apache/hudi/sink/CommitSink.java | 153 -----------
.../apache/hudi/sink/InstantGenerateOperator.java | 297 ---------------------
.../hudi/sink/KeyedWriteProcessFunction.java | 194 --------------
.../hudi/sink/KeyedWriteProcessOperator.java | 66 -----
.../JsonStringToHoodieRecordMapFunction.java | 88 ------
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 82 +++---
.../hudi/streamer/HoodieFlinkStreamerV2.java | 110 --------
.../org/apache/hudi/sink/StreamWriteITCase.java | 73 -----
.../TestJsonStringToHoodieRecordMapFunction.java | 89 ------
10 files changed, 36 insertions(+), 1146 deletions(-)
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/exception/HoodieFlinkStreamerException.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/CommitSink.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/InstantGenerateOperator.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/KeyedWriteProcessFunction.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/KeyedWriteProcessOperator.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/transform/JsonStringToHoodieRecordMapFunction.java
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamerV2.java
delete mode 100644
hudi-flink/src/test/java/org/apache/hudi/sink/transform/TestJsonStringToHoodieRecordMapFunction.java
