Package org.apache.iceberg.io
Interface FileAppenderFactory<T>
-
- Type Parameters:
T
- data type of the rows to append.
- All Known Implementing Classes:
FlinkAppenderFactory
,GenericAppenderFactory
public interface FileAppenderFactory<T>
Factory to create a newFileAppender
to write records.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description FileAppender<T>
newAppender(OutputFile outputFile, FileFormat fileFormat)
Create a newFileAppender
.DataWriter<T>
newDataWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newDataWriter
.EqualityDeleteWriter<T>
newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newEqualityDeleteWriter
.PositionDeleteWriter<T>
newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newPositionDeleteWriter
.
-
-
-
Method Detail
-
newAppender
FileAppender<T> newAppender(OutputFile outputFile, FileFormat fileFormat)
Create a newFileAppender
.- Parameters:
outputFile
- an OutputFile used to create an output stream.fileFormat
- File format.- Returns:
- a newly created
FileAppender
-
newDataWriter
DataWriter<T> newDataWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newDataWriter
.- Parameters:
outputFile
- 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
EqualityDeleteWriter<T> newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newEqualityDeleteWriter
.- 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
PositionDeleteWriter<T> newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
Create a newPositionDeleteWriter
.- 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 position deletes
-
-