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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FileAppender<org.apache.flink.table.data.RowData>
newAppender(OutputFile outputFile, FileFormat format)
Create a newFileAppender
.DataWriter<org.apache.flink.table.data.RowData>
newDataWriter(EncryptedOutputFile file, FileFormat format, StructLike partition)
Create a newDataWriter
.EqualityDeleteWriter<org.apache.flink.table.data.RowData>
newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newEqualityDeleteWriter
.PositionDeleteWriter<org.apache.flink.table.data.RowData>
newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newPositionDeleteWriter
.-
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 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 newFileAppender
.- Specified by:
newAppender
in interfaceFileAppenderFactory<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 newDataWriter
.- Specified by:
newDataWriter
in interfaceFileAppenderFactory<org.apache.flink.table.data.RowData>
- Parameters:
file
- an OutputFile used to create an output stream.format
- a file formatpartition
- 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 newEqualityDeleteWriter
.- Specified by:
newEqDeleteWriter
in interfaceFileAppenderFactory<org.apache.flink.table.data.RowData>
- Parameters:
outputFile
- an OutputFile used to create an output stream.format
- a file formatpartition
- 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 newPositionDeleteWriter
.- Specified by:
newPosDeleteWriter
in interfaceFileAppenderFactory<org.apache.flink.table.data.RowData>
- Parameters:
outputFile
- an OutputFile used to create an output stream.format
- a file formatpartition
- a tuple of partition values- Returns:
- a newly created
PositionDeleteWriter
for position deletes
-
-