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