This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 8967729bea Build: Bump roaringbitmap from 1.3.0 to 1.6.0 (#14991)
add dc708e675d Flink: Backport: Dynamic Sink: Refactor write result
aggregation (#15054)
No new revisions were added by this update.
Summary of changes:
.../apache/iceberg/flink/sink/CommitSummary.java | 7 +-
.../flink/sink/dynamic/DynamicCommittable.java | 24 +-
.../sink/dynamic/DynamicCommittableSerializer.java | 65 +++--
.../flink/sink/dynamic/DynamicCommitter.java | 182 ++++----------
.../flink/sink/dynamic/DynamicWriteResult.java | 23 +-
.../sink/dynamic/DynamicWriteResultAggregator.java | 53 ++--
.../sink/dynamic/DynamicWriteResultSerializer.java | 6 +-
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 6 +-
.../iceberg/flink/sink/dynamic/TableKey.java | 0
.../iceberg/flink/sink/dynamic/WriteTarget.java | 13 -
.../dynamic/TestDynamicCommittableSerializer.java | 86 +++++--
.../flink/sink/dynamic/TestDynamicCommitter.java | 249 ++++++++-----------
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 93 +++++++
.../sink/dynamic/TestDynamicIcebergSinkPerf.java | 6 +-
.../dynamic/TestDynamicWriteResultAggregator.java | 125 ++++++++--
.../dynamic/TestDynamicWriteResultSerializer.java | 12 +-
.../apache/iceberg/flink/sink/CommitSummary.java | 7 +-
.../flink/sink/dynamic/DynamicCommittable.java | 24 +-
.../sink/dynamic/DynamicCommittableSerializer.java | 65 +++--
.../flink/sink/dynamic/DynamicCommitter.java | 182 ++++----------
.../flink/sink/dynamic/DynamicWriteResult.java | 23 +-
.../sink/dynamic/DynamicWriteResultAggregator.java | 53 ++--
.../sink/dynamic/DynamicWriteResultSerializer.java | 6 +-
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 6 +-
.../iceberg/flink/sink/dynamic/TableKey.java | 0
.../iceberg/flink/sink/dynamic/WriteTarget.java | 13 -
.../dynamic/TestDynamicCommittableSerializer.java | 86 +++++--
.../flink/sink/dynamic/TestDynamicCommitter.java | 275 ++++++++-------------
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 93 +++++++
.../sink/dynamic/TestDynamicIcebergSinkPerf.java | 6 +-
.../dynamic/TestDynamicWriteResultAggregator.java | 125 ++++++++--
.../dynamic/TestDynamicWriteResultSerializer.java | 12 +-
32 files changed, 1095 insertions(+), 831 deletions(-)
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableKey.java
(100%)
copy flink/{v2.0 =>
v2.1}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableKey.java
(100%)
