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

Posted to commits@iceberg.apache.org by st...@apache.org on 2025/10/14 15:23:17 UTC

(iceberg) branch main updated (02fdf38cad -> a704de7a2b)

This is an automated email from the ASF dual-hosted git repository.

stevenwu pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


    from 02fdf38cad Flink: Move write from AppenderFactory to FileWriterFactory (#14271)
     add a704de7a2b Flink: Backport move write from AppenderFactory to FileWriterFactory (#14325)

No new revisions were added by this update.

Summary of changes:
 .../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 +--
 .../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 +--
 24 files changed, 416 insertions(+), 314 deletions(-)