Package org.apache.iceberg.flink.sink

Class FlinkAppenderFactory

java.lang.Object

org.apache.iceberg.flink.sink.FlinkAppenderFactory

All Implemented Interfaces:

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

public class FlinkAppenderFactory
extends Object
implements FileAppenderFactory<org.apache.flink.table.data.RowData>, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkAppenderFactory(Table table, Schema schema, org.apache.flink.table.types.logical.RowType flinkSchema, Map<String,String> props, PartitionSpec spec, int[] equalityFieldIds, Schema eqDeleteRowSchema, Schema posDeleteRowSchema)

Method Summary

Modifier and Type	Method	Description
FileAppender<org.apache.flink.table.data.RowData>	newAppender(OutputFile outputFile, FileFormat format)	Create a new FileAppender.
DataWriter<org.apache.flink.table.data.RowData>	newDataWriter(EncryptedOutputFile file, FileFormat format, StructLike partition)	Create a new DataWriter.
EqualityDeleteWriter<org.apache.flink.table.data.RowData>	newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)	Create a new EqualityDeleteWriter.
PositionDeleteWriter<org.apache.flink.table.data.RowData>	newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)	Create a new PositionDeleteWriter.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.io.FileAppenderFactory

newAppender

Constructor Details

FlinkAppenderFactory

public FlinkAppenderFactory(Table table,
 Schema schema,
 org.apache.flink.table.types.logical.RowType flinkSchema,
 Map<String,String> props,
 PartitionSpec spec,
 int[] equalityFieldIds,
 Schema eqDeleteRowSchema,
 Schema posDeleteRowSchema)

Method Details

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

newDataWriter

public DataWriter<org.apache.flink.table.data.RowData> newDataWriter(EncryptedOutputFile file,
 FileFormat format,
 StructLike partition)

Description copied from interface: FileAppenderFactory

Create a new DataWriter.

Specified by:

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

Parameters:

file - an OutputFile used to create an output stream.

format - a file format

partition - a tuple of partition values

Returns:

a newly created DataWriter for rows

newEqDeleteWriter

public EqualityDeleteWriter<org.apache.flink.table.data.RowData> newEqDeleteWriter(EncryptedOutputFile outputFile,
 FileFormat format,
 StructLike partition)

Description copied from interface: FileAppenderFactory

Create a new EqualityDeleteWriter.

Specified by:

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

Parameters:

outputFile - an OutputFile used to create an output stream.

format - a file format

partition - a tuple of partition values

Returns:

a newly created EqualityDeleteWriter for equality deletes

newPosDeleteWriter

public PositionDeleteWriter<org.apache.flink.table.data.RowData> newPosDeleteWriter(EncryptedOutputFile outputFile,
 FileFormat format,
 StructLike partition)

Description copied from interface: FileAppenderFactory

Create a new PositionDeleteWriter.

Specified by:

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

Parameters:

outputFile - an OutputFile used to create an output stream.

format - a file format

partition - a tuple of partition values

Returns:

a newly created PositionDeleteWriter for position deletes