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 8b19ec9 [HUDI-2252] Default consumes from the latest instant for
flink streaming reader (#3368)
add c4e45a0 [HUDI-2254] Builtin sort operator for flink bulk insert
(#3372)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/client/model/HoodieRowData.java | 2 +-
.../apache/hudi/configuration/FlinkOptions.java | 26 +++--
.../hudi/sink/bulk/BulkInsertWriterHelper.java | 2 +-
.../org/apache/hudi/sink/bulk/RowDataKeyGen.java | 4 +-
.../apache/hudi/sink/bulk/sort/SortOperator.java | 126 +++++++++++++++++++++
.../hudi/sink/bulk/sort/SortOperatorGen.java | 58 ++++++++++
.../org/apache/hudi/table/HoodieTableSink.java | 52 +++++----
.../java/org/apache/hudi/util/StreamerUtil.java | 1 -
.../apache/hudi/table/HoodieDataSourceITCase.java | 2 +-
9 files changed, 235 insertions(+), 38 deletions(-)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperator.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java
