You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iceberg.apache.org by pv...@apache.org on 2025/10/14 07:28:26 UTC

(iceberg) branch main updated (58940f3cac -> 02fdf38cad)

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(-)