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, org.apache.iceberg.io.FileWriterFactory<T>
Direct Known Subclasses:
GenericFileWriterFactory
public abstract class RegistryBasedFileWriterFactory<T,S> extends Object implements org.apache.iceberg.io.FileWriterFactory<T>, Serializable
A base writer factory to be extended by query engine integrations.
See Also:

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    RegistryBasedFileWriterFactory(org.apache.iceberg.Table table, org.apache.iceberg.FileFormat dataFileFormat, Class<T> inputType, org.apache.iceberg.Schema dataSchema, org.apache.iceberg.SortOrder dataSortOrder, org.apache.iceberg.FileFormat deleteFileFormat, int[] equalityFieldIds, org.apache.iceberg.Schema equalityDeleteRowSchema, org.apache.iceberg.SortOrder equalityDeleteSortOrder, Map<String,String> writerProperties, S inputSchema, S equalityDeleteInputSchema)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected S
    equalityDeleteInputSchema()
     
    protected S
    inputSchema()
     
    org.apache.iceberg.io.DataWriter<T>
    newDataWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
     
    org.apache.iceberg.deletes.EqualityDeleteWriter<T>
    newEqualityDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
     
    org.apache.iceberg.deletes.PositionDeleteWriter<T>
    newPositionDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RegistryBasedFileWriterFactory

      protected RegistryBasedFileWriterFactory(org.apache.iceberg.Table table, org.apache.iceberg.FileFormat dataFileFormat, Class<T> inputType, org.apache.iceberg.Schema dataSchema, org.apache.iceberg.SortOrder dataSortOrder, org.apache.iceberg.FileFormat deleteFileFormat, int[] equalityFieldIds, org.apache.iceberg.Schema equalityDeleteRowSchema, org.apache.iceberg.SortOrder equalityDeleteSortOrder, Map<String,String> writerProperties, S inputSchema, S equalityDeleteInputSchema)

  • Method Details

    • inputSchema

      protected S inputSchema()

    • equalityDeleteInputSchema

      protected S equalityDeleteInputSchema()

    • newDataWriter

      public org.apache.iceberg.io.DataWriter<T> newDataWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
      Specified by:
      newDataWriter in interface org.apache.iceberg.io.FileWriterFactory<T>

    • newEqualityDeleteWriter

      public org.apache.iceberg.deletes.EqualityDeleteWriter<T> newEqualityDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
      Specified by:
      newEqualityDeleteWriter in interface org.apache.iceberg.io.FileWriterFactory<T>

    • newPositionDeleteWriter

      public org.apache.iceberg.deletes.PositionDeleteWriter<T> newPositionDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.PartitionSpec spec, org.apache.iceberg.StructLike partition)
      Specified by:
      newPositionDeleteWriter in interface org.apache.iceberg.io.FileWriterFactory<T>