Package org.apache.iceberg.data
Class RegistryBasedFileWriterFactory<T,S>
java.lang.Object
org.apache.iceberg.data.RegistryBasedFileWriterFactory<T,S>
- Type Parameters:
T- row type
- All Implemented Interfaces:
Serializable,FileWriterFactory<T>
- Direct Known Subclasses:
FlinkFileWriterFactory,GenericFileWriterFactory
public abstract class RegistryBasedFileWriterFactory<T,S>
extends Object
implements FileWriterFactory<T>, Serializable
A base writer factory to be extended by query engine integrations.
- See Also:
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedRegistryBasedFileWriterFactory(Table table, FileFormat dataFileFormat, Class<T> inputType, Schema dataSchema, SortOrder dataSortOrder, FileFormat deleteFileFormat, int[] equalityFieldIds, Schema equalityDeleteRowSchema, SortOrder equalityDeleteSortOrder, Map<String, String> writerProperties, S inputSchema, S equalityDeleteInputSchema) -
Method Summary
Modifier and TypeMethodDescriptionprotected Sprotected SnewDataWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition) Creates a newDataWriter.newEqualityDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition) Creates a newEqualityDeleteWriter.newPositionDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition) Creates a newPositionDeleteWriter.
-
Constructor Details
-
RegistryBasedFileWriterFactory
protected RegistryBasedFileWriterFactory(Table table, FileFormat dataFileFormat, Class<T> inputType, Schema dataSchema, SortOrder dataSortOrder, FileFormat deleteFileFormat, int[] equalityFieldIds, Schema equalityDeleteRowSchema, SortOrder equalityDeleteSortOrder, Map<String, String> writerProperties, S inputSchema, S equalityDeleteInputSchema)
-
-
Method Details
-
inputSchema
-
equalityDeleteInputSchema
-
newDataWriter
public DataWriter<T> newDataWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition) Description copied from interface:FileWriterFactoryCreates a newDataWriter.- Specified by:
newDataWriterin 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:FileWriterFactoryCreates a newEqualityDeleteWriter.- Specified by:
newEqualityDeleteWriterin 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:FileWriterFactoryCreates a newPositionDeleteWriter.- Specified by:
newPositionDeleteWriterin 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
-