This is an automated email from the ASF dual-hosted git repository.
dweeks pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 2e291c2b67 Core: Default to zstd compression for Parquet in new tables
(#8593)
add d213b16627 Flink: table supplier in writer operator for optional table
refresh (#8555)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/io/OutputFileFactory.java | 38 +++++++--
flink/v1.17/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 | 91 ++++++++++++++++++++++
.../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 | 61 +++++++++++++++
.../org/apache/iceberg/flink/TestTableLoader.java | 5 ++
.../flink/sink/TestCachingTableSupplier.java | 81 +++++++++++++++++++
.../flink/sink/TestCompressionSettings.java | 2 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 25 ++++++
.../iceberg/flink/sink/TestFlinkManifest.java | 19 ++---
.../flink/sink/TestIcebergStreamWriter.java | 2 +-
19 files changed, 480 insertions(+), 59 deletions(-)
create mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
create mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
create mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
