Package org.apache.iceberg.flink.sink

Class FlinkAppenderFactory

java.lang.Object

org.apache.iceberg.flink.sink.FlinkAppenderFactory

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkAppenderFactory(Table table, Schema schema, org.apache.flink.table.types.logical.RowType flinkSchema, java.util.Map<java.lang.String,java.lang.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

Constructor Detail

FlinkAppenderFactory

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

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

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