This is an automated email from the ASF dual-hosted git repository.
etudenhoefner pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from db66706ef8 Python: Remove D106 Docstring Issue (#8618)
add 37d48901c6 Flink 1.15, 1.16: Table supplier in writer operator for
optional table refresh
No new revisions were added by this update.
Summary of changes:
flink/v1.15/build.gradle | 5 ++
.../org/apache/iceberg/flink/FlinkConfParser.java | 29 +++++++++
.../org/apache/iceberg/flink/FlinkWriteConf.java | 18 ++++++
.../apache/iceberg/flink/FlinkWriteOptions.java | 6 ++
.../java/org/apache/iceberg/flink/TableLoader.java | 14 +++++
.../iceberg/flink/sink/CachingTableSupplier.java | 0
.../iceberg/flink/sink/FlinkManifestUtil.java | 18 +++---
.../org/apache/iceberg/flink/sink/FlinkSink.java | 33 +++++++---
.../iceberg/flink/sink/IcebergFilesCommitter.java | 5 +-
.../flink/sink/ManifestOutputFileFactory.java | 16 ++---
.../flink/sink/RowDataTaskWriterFactory.java | 71 +++++++++++++++++++---
.../apache/iceberg/flink/TestFlinkConfParser.java | 0
.../org/apache/iceberg/flink/TestTableLoader.java | 5 ++
.../flink/sink/TestCachingTableSupplier.java | 0
.../flink/sink/TestCompressionSettings.java | 2 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 25 ++++++++
.../iceberg/flink/sink/TestFlinkManifest.java | 19 +++---
.../flink/sink/TestIcebergStreamWriter.java | 2 +-
flink/v1.16/build.gradle | 5 ++
.../org/apache/iceberg/flink/FlinkConfParser.java | 29 +++++++++
.../org/apache/iceberg/flink/FlinkWriteConf.java | 18 ++++++
.../apache/iceberg/flink/FlinkWriteOptions.java | 6 ++
.../java/org/apache/iceberg/flink/TableLoader.java | 14 +++++
.../iceberg/flink/sink/CachingTableSupplier.java | 0
.../iceberg/flink/sink/FlinkManifestUtil.java | 18 +++---
.../org/apache/iceberg/flink/sink/FlinkSink.java | 33 +++++++---
.../iceberg/flink/sink/IcebergFilesCommitter.java | 5 +-
.../flink/sink/ManifestOutputFileFactory.java | 16 ++---
.../flink/sink/RowDataTaskWriterFactory.java | 71 +++++++++++++++++++---
.../apache/iceberg/flink/TestFlinkConfParser.java | 0
.../org/apache/iceberg/flink/TestTableLoader.java | 5 ++
.../flink/sink/TestCachingTableSupplier.java | 0
.../flink/sink/TestCompressionSettings.java | 2 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 25 ++++++++
.../iceberg/flink/sink/TestFlinkManifest.java | 19 +++---
.../flink/sink/TestIcebergStreamWriter.java | 2 +-
.../org/apache/iceberg/flink/FlinkWriteConf.java | 6 +-
.../apache/iceberg/flink/FlinkWriteOptions.java | 4 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 2 +-
39 files changed, 440 insertions(+), 108 deletions(-)
copy flink/{v1.17 =>
v1.15}/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
(100%)
copy flink/{v1.17 =>
v1.15}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
(100%)
copy flink/{v1.17 =>
v1.15}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
(100%)
copy flink/{v1.17 =>
v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
(100%)
copy flink/{v1.17 =>
v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
(100%)
copy flink/{v1.17 =>
v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
(100%)
