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 new FileAppender to write records.

Method Summary

Modifier and Type	Method	Description
default FileAppender<T>	newAppender(EncryptedOutputFile outputFile, FileFormat fileFormat)	Create a new FileAppender.
FileAppender<T>	newAppender(OutputFile outputFile, FileFormat fileFormat)	Create a new FileAppender.
DataWriter<T>	newDataWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)	Create a new DataWriter.
EqualityDeleteWriter<T>	newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)	Create a new EqualityDeleteWriter.
PositionDeleteWriter<T>	newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)	Create a new PositionDeleteWriter.

Method Detail

newAppender

FileAppender<T> newAppender(OutputFile outputFile,
                            FileFormat fileFormat)

Create a new FileAppender.

Parameters:

outputFile - an OutputFile used to create an output stream.

fileFormat - File format.

Returns:

a newly created FileAppender

newAppender

default FileAppender<T> newAppender(EncryptedOutputFile outputFile,
                                    FileFormat fileFormat)

Create a new FileAppender.

Parameters:

outputFile - an EncryptedOutputFile 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 new DataWriter.

Parameters:

outputFile - 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

EqualityDeleteWriter<T> newEqDeleteWriter(EncryptedOutputFile outputFile,
                                          FileFormat format,
                                          StructLike partition)

Create a new EqualityDeleteWriter.

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

PositionDeleteWriter<T> newPosDeleteWriter(EncryptedOutputFile outputFile,
                                           FileFormat format,
                                           StructLike partition)

Create a new PositionDeleteWriter.

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