org.apache.iceberg.flink.sink

Class RowDataTaskWriterFactory.FlinkFileAppenderFactory

java.lang.Object

org.apache.iceberg.flink.sink.RowDataTaskWriterFactory.FlinkFileAppenderFactory

All Implemented Interfaces:

java.io.Serializable, FileAppenderFactory<org.apache.flink.table.data.RowData>

Enclosing class:

RowDataTaskWriterFactory

public static class RowDataTaskWriterFactory.FlinkFileAppenderFactory
extends java.lang.Object
implements FileAppenderFactory<org.apache.flink.table.data.RowData>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlinkFileAppenderFactory(Schema schema, org.apache.flink.table.types.logical.RowType flinkSchema, java.util.Map<java.lang.String,java.lang.String> props)

Method Summary

Modifier and Type	Method and Description
FileAppender<org.apache.flink.table.data.RowData>	newAppender(OutputFile outputFile, FileFormat format) Create a new FileAppender.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkFileAppenderFactory

public FlinkFileAppenderFactory(Schema schema,
                                org.apache.flink.table.types.logical.RowType flinkSchema,
                                java.util.Map<java.lang.String,java.lang.String> props)

Method Detail

newAppender

public FileAppender<org.apache.flink.table.data.RowData> newAppender(OutputFile outputFile,
                                                                     FileFormat format)

Description copied from interface: FileAppenderFactory

Create a new FileAppender.

Specified by:

newAppender in interface FileAppenderFactory<org.apache.flink.table.data.RowData>

Parameters:

outputFile - an OutputFile used to create an output stream.

format - File format.

Returns:

a newly created FileAppender