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 4a4d73408a Core: Add storage credentials to
FetchPlanningResultResponse (#14994)
add 6f7b5688da Flink: Dynamic Sink: Refactor write result aggregation
(#14810)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iceberg/io/WriteResult.java | 11 +
.../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 | 84 +++++++
.../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 +-
17 files changed, 639 insertions(+), 406 deletions(-)
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableKey.java
