Package org.apache.iceberg.data
Class BaseFileWriterFactory<T>
- java.lang.Object
-
- org.apache.iceberg.data.BaseFileWriterFactory<T>
-
- All Implemented Interfaces:
FileWriterFactory<T>
public abstract class BaseFileWriterFactory<T> extends java.lang.Object implements FileWriterFactory<T>
A base writer factory to be extended by query engine integrations.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
BaseFileWriterFactory(Table table, FileFormat dataFileFormat, Schema dataSchema, SortOrder dataSortOrder, FileFormat deleteFileFormat, int[] equalityFieldIds, Schema equalityDeleteRowSchema, SortOrder equalityDeleteSortOrder, Schema positionDeleteRowSchema)
-
Method Summary
-
-
-
Constructor Detail
-
BaseFileWriterFactory
protected BaseFileWriterFactory(Table table, FileFormat dataFileFormat, Schema dataSchema, SortOrder dataSortOrder, FileFormat deleteFileFormat, int[] equalityFieldIds, Schema equalityDeleteRowSchema, SortOrder equalityDeleteSortOrder, Schema positionDeleteRowSchema)
-
-
Method Detail
-
configureDataWrite
protected abstract void configureDataWrite(Avro.DataWriteBuilder builder)
-
configureEqualityDelete
protected abstract void configureEqualityDelete(Avro.DeleteWriteBuilder builder)
-
configurePositionDelete
protected abstract void configurePositionDelete(Avro.DeleteWriteBuilder builder)
-
configureDataWrite
protected abstract void configureDataWrite(Parquet.DataWriteBuilder builder)
-
configureEqualityDelete
protected abstract void configureEqualityDelete(Parquet.DeleteWriteBuilder builder)
-
configurePositionDelete
protected abstract void configurePositionDelete(Parquet.DeleteWriteBuilder builder)
-
configureDataWrite
protected abstract void configureDataWrite(ORC.DataWriteBuilder builder)
-
configureEqualityDelete
protected abstract void configureEqualityDelete(ORC.DeleteWriteBuilder builder)
-
configurePositionDelete
protected abstract void configurePositionDelete(ORC.DeleteWriteBuilder builder)
-
newDataWriter
public DataWriter<T> newDataWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
Description copied from interface:FileWriterFactory
Creates a newDataWriter
.- Specified by:
newDataWriter
in interfaceFileWriterFactory<T>
- Parameters:
file
- the output filespec
- the partition spec written data belongs topartition
- the partition written data belongs to or null if the spec is unpartitioned- Returns:
- the constructed data writer
-
newEqualityDeleteWriter
public EqualityDeleteWriter<T> newEqualityDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
Description copied from interface:FileWriterFactory
Creates a newEqualityDeleteWriter
.- Specified by:
newEqualityDeleteWriter
in interfaceFileWriterFactory<T>
- Parameters:
file
- the output filespec
- the partition spec written deletes belong topartition
- the partition written deletes belong to or null if the spec is unpartitioned- Returns:
- the constructed equality delete writer
-
newPositionDeleteWriter
public PositionDeleteWriter<T> newPositionDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
Description copied from interface:FileWriterFactory
Creates a newPositionDeleteWriter
.- Specified by:
newPositionDeleteWriter
in interfaceFileWriterFactory<T>
- Parameters:
file
- the output filespec
- the partition spec written deletes belong topartition
- the partition written deletes belong to or null if the spec is unpartitioned- Returns:
- the constructed position delete writer
-
dataSchema
protected Schema dataSchema()
-
equalityDeleteRowSchema
protected Schema equalityDeleteRowSchema()
-
positionDeleteRowSchema
protected Schema positionDeleteRowSchema()
-
-