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 5b50afe8f2 Core, REST: Add context aware response parsing (#13191)
add 81b74fc0b9 Flink: Backport dynamic Iceberg Sink: Add sink / core
processing logic / benchmarking to Flink 1.19 / 1.20 (#13341)
No new revisions were added by this update.
Summary of changes:
...namicRecordSerializerDeserializerBenchmark.java | 0
.../org/apache/iceberg/flink/FlinkConfParser.java | 7 +++
.../org/apache/iceberg/flink/FlinkWriteConf.java | 4 ++
.../org/apache/iceberg/flink/sink/FlinkSink.java | 49 +-----------------
.../org/apache/iceberg/flink/sink/IcebergSink.java | 49 +-----------------
.../org/apache/iceberg/flink/sink/SinkUtil.java | 59 +++++++++++++++++++++-
.../flink/sink/dynamic/DynamicCommitter.java | 3 +-
.../flink/sink/dynamic/DynamicIcebergSink.java | 4 +-
.../flink/sink/dynamic/DynamicRecordGenerator.java | 0
.../flink/sink/dynamic/DynamicRecordProcessor.java | 0
.../flink/sink/dynamic/HashKeyGenerator.java | 16 +++---
.../org/apache/iceberg/flink/SimpleDataUtil.java | 22 +++++++-
.../java/org/apache/iceberg/flink/TestHelpers.java | 2 +-
.../flink/sink/TestFlinkIcebergSinkBase.java | 5 +-
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 2 +-
.../sink/dynamic/TestDynamicIcebergSinkPerf.java | 0
...namicRecordSerializerDeserializerBenchmark.java | 0
.../org/apache/iceberg/flink/FlinkConfParser.java | 7 +++
.../org/apache/iceberg/flink/FlinkWriteConf.java | 4 ++
.../org/apache/iceberg/flink/sink/FlinkSink.java | 49 +-----------------
.../org/apache/iceberg/flink/sink/IcebergSink.java | 49 +-----------------
.../org/apache/iceberg/flink/sink/SinkUtil.java | 59 +++++++++++++++++++++-
.../flink/sink/dynamic/DynamicCommitter.java | 3 +-
.../flink/sink/dynamic/DynamicIcebergSink.java | 4 +-
.../flink/sink/dynamic/DynamicRecordGenerator.java | 0
.../flink/sink/dynamic/DynamicRecordProcessor.java | 0
.../flink/sink/dynamic/HashKeyGenerator.java | 16 +++---
.../org/apache/iceberg/flink/SimpleDataUtil.java | 22 +++++++-
.../org/apache/iceberg/flink/TestFlinkFilters.java | 1 +
.../java/org/apache/iceberg/flink/TestHelpers.java | 2 +-
.../flink/sink/TestFlinkIcebergSinkBase.java | 5 +-
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 2 +-
.../sink/dynamic/TestDynamicIcebergSinkPerf.java | 0
33 files changed, 223 insertions(+), 222 deletions(-)
copy flink/{v2.0 =>
v1.19}/flink/src/jmh/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordSerializerDeserializerBenchmark.java
(100%)
copy flink/{v2.0 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java
(99%)
copy flink/{v2.0 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordGenerator.java
(100%)
copy flink/{v2.0 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordProcessor.java
(100%)
copy flink/{v2.0 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSink.java
(99%)
copy flink/{v2.0 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSinkPerf.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/jmh/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordSerializerDeserializerBenchmark.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java
(99%)
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordGenerator.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordProcessor.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSink.java
(99%)
copy flink/{v2.0 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSinkPerf.java
(100%)
