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 58940f3cac Test: Remove unused methods and fix typo (#14305)
add 02fdf38cad Flink: Move write from AppenderFactory to FileWriterFactory
(#14271)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iceberg/io/BaseTaskWriter.java | 40 +++++++++-
.../apache/iceberg/io/PartitionedFanoutWriter.java | 10 +++
.../org/apache/iceberg/io/PartitionedWriter.java | 10 +++
.../org/apache/iceberg/io/UnpartitionedWriter.java | 11 +++
.../apache/iceberg/data/BaseFileWriterFactory.java | 39 +++++++++-
.../apache/iceberg/io/TestFileWriterFactory.java | 12 +++
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 6 +-
.../iceberg/flink/sink/FlinkAppenderFactory.java | 5 ++
.../iceberg/flink/sink/FlinkFileWriterFactory.java | 49 +++++++-----
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 6 +-
.../flink/sink/RowDataTaskWriterFactory.java | 66 ++++++++--------
.../flink/sink/UnpartitionedDeltaWriter.java | 6 +-
.../org/apache/iceberg/flink/SimpleDataUtil.java | 91 +++++++++++++++-------
.../flink/sink/TestCompressionSettings.java | 10 ++-
.../iceberg/flink/sink/TestFlinkManifest.java | 27 +++----
.../iceberg/flink/sink/TestIcebergCommitter.java | 34 ++++----
.../flink/sink/TestIcebergFilesCommitter.java | 54 ++++++-------
.../flink/sink/dynamic/TestDynamicWriter.java | 11 +--
18 files changed, 326 insertions(+), 161 deletions(-)
