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 ac0d206359 Spec: Minor modifications for v3 (#10948)
add ce772a6ecd Flink: backport PR #10859 for range distribution (#10990)
No new revisions were added by this update.
Summary of changes:
.../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 | 0
.../sink/TestFlinkIcebergSinkDistributionMode.java | 314 +++++++++++++++++++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
.../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 | 0
.../iceberg/flink/TestFlinkTableSinkExtended.java | 92 ++++++
.../sink/TestFlinkIcebergSinkDistributionMode.java | 314 +++++++++++++++++++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
15 files changed, 1122 insertions(+), 74 deletions(-)
copy flink/{v1.19 =>
v1.18}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
(100%)
