This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 9ddde5077b Docs: Update MRAP endpoint and add notebook link (#9362)
add ed07fd1cd7 Flink: put everything together for range distribution in
Flink sink (#10859)
No new revisions were added by this update.
Summary of changes:
docs/docs/flink-configuration.md | 64 ++++-
docs/docs/flink-writes.md | 101 +++++++
.../org/apache/iceberg/flink/FlinkConfParser.java | 27 ++
.../org/apache/iceberg/flink/FlinkWriteConf.java | 21 ++
.../apache/iceberg/flink/FlinkWriteOptions.java | 14 +
.../org/apache/iceberg/flink/sink/FlinkSink.java | 155 +++++++---
.../shuffle/DataStatisticsOperatorFactory.java | 98 +++++++
.../iceberg/flink/TestFlinkTableSinkExtended.java | 92 ++++++
.../sink/TestFlinkIcebergSinkDistributionMode.java | 314 +++++++++++++++++++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
10 files changed, 859 insertions(+), 48 deletions(-)
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
