public abstract class BaseFileWriterFactory<T> extends java.lang.Object implements FileWriterFactory<T>
Modifier | Constructor and Description |
---|---|
protected |
BaseFileWriterFactory(Table table,
FileFormat dataFileFormat,
Schema dataSchema,
SortOrder dataSortOrder,
FileFormat deleteFileFormat,
int[] equalityFieldIds,
Schema equalityDeleteRowSchema,
SortOrder equalityDeleteSortOrder,
Schema positionDeleteRowSchema) |
protected BaseFileWriterFactory(Table table, FileFormat dataFileFormat, Schema dataSchema, SortOrder dataSortOrder, FileFormat deleteFileFormat, int[] equalityFieldIds, Schema equalityDeleteRowSchema, SortOrder equalityDeleteSortOrder, Schema positionDeleteRowSchema)
protected abstract void configureDataWrite(Avro.DataWriteBuilder builder)
protected abstract void configureEqualityDelete(Avro.DeleteWriteBuilder builder)
protected abstract void configurePositionDelete(Avro.DeleteWriteBuilder builder)
protected abstract void configureDataWrite(Parquet.DataWriteBuilder builder)
protected abstract void configureEqualityDelete(Parquet.DeleteWriteBuilder builder)
protected abstract void configurePositionDelete(Parquet.DeleteWriteBuilder builder)
protected abstract void configureDataWrite(ORC.DataWriteBuilder builder)
protected abstract void configureEqualityDelete(ORC.DeleteWriteBuilder builder)
protected abstract void configurePositionDelete(ORC.DeleteWriteBuilder builder)
public DataWriter<T> newDataWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
FileWriterFactory
DataWriter
.newDataWriter
in interface FileWriterFactory<T>
file
- the output filespec
- the partition spec written data belongs topartition
- the partition written data belongs to or null if the spec is unpartitionedpublic EqualityDeleteWriter<T> newEqualityDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
FileWriterFactory
EqualityDeleteWriter
.newEqualityDeleteWriter
in interface FileWriterFactory<T>
file
- the output filespec
- the partition spec written deletes belong topartition
- the partition written deletes belong to or null if the spec is unpartitionedpublic PositionDeleteWriter<T> newPositionDeleteWriter(EncryptedOutputFile file, PartitionSpec spec, StructLike partition)
FileWriterFactory
PositionDeleteWriter
.newPositionDeleteWriter
in interface FileWriterFactory<T>
file
- the output filespec
- the partition spec written deletes belong topartition
- the partition written deletes belong to or null if the spec is unpartitionedprotected Schema dataSchema()
protected Schema equalityDeleteRowSchema()
protected Schema positionDeleteRowSchema()