Package org.apache.iceberg.io

Interface FileWriterFactory<T>

All Known Implementing Classes:

BaseFileWriterFactory

public interface FileWriterFactory<T>

A factory for creating data and delete writers.

Method Summary

Modifier and Type	Method	Description
DataWriter<T>	newDataWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)	Creates a new DataWriter.
EqualityDeleteWriter<T>	newEqualityDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)	Creates a new EqualityDeleteWriter.
PositionDeleteWriter<T>	newPositionDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)	Creates a new PositionDeleteWriter.

Method Detail

newDataWriter

DataWriter<T> newDataWriter(EncryptedOutputFile file,
                            PartitionSpec spec,
                            StructLike partition)

Creates a new DataWriter.

Parameters:

file - the output file

spec - the partition spec written data belongs to

partition - the partition written data belongs to or null if the spec is unpartitioned

Returns:

the constructed data writer

newEqualityDeleteWriter

EqualityDeleteWriter<T> newEqualityDeleteWriter(EncryptedOutputFile file,
                                                PartitionSpec spec,
                                                StructLike partition)

Creates a new EqualityDeleteWriter.

Parameters:

file - the output file

spec - the partition spec written deletes belong to

partition - the partition written deletes belong to or null if the spec is unpartitioned

Returns:

the constructed equality delete writer

newPositionDeleteWriter

PositionDeleteWriter<T> newPositionDeleteWriter(EncryptedOutputFile file,
                                                PartitionSpec spec,
                                                StructLike partition)

Creates a new PositionDeleteWriter.

Parameters:

file - the output file

spec - the partition spec written deletes belong to

partition - the partition written deletes belong to or null if the spec is unpartitioned

Returns:

the constructed position delete writer