Package org.apache.iceberg.data

Class GenericAppenderFactory

java.lang.Object
org.apache.iceberg.data.GenericAppenderFactory
All Implemented Interfaces:
org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>
public class GenericAppenderFactory extends Object implements org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>
Factory to create a new FileAppender to write Records.

  • Constructor Summary

    Constructors
    Constructor
    Description
    GenericAppenderFactory(org.apache.iceberg.Schema schema)
     
    GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec)
     
    GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema, org.apache.iceberg.Schema posDeleteRowSchema)
     
    GenericAppenderFactory(org.apache.iceberg.Table table, org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, Map<String,String> config, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema, org.apache.iceberg.Schema posDeleteRowSchema)
    Constructor for GenericAppenderFactory.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record>
    newAppender(org.apache.iceberg.encryption.EncryptedOutputFile encryptedOutputFile, org.apache.iceberg.FileFormat fileFormat)
     
    org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record>
    newAppender(org.apache.iceberg.io.OutputFile outputFile, org.apache.iceberg.FileFormat fileFormat)
     
    org.apache.iceberg.io.DataWriter<org.apache.iceberg.data.Record>
    newDataWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
     
    org.apache.iceberg.deletes.EqualityDeleteWriter<org.apache.iceberg.data.Record>
    newEqDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
     
    org.apache.iceberg.deletes.PositionDeleteWriter<org.apache.iceberg.data.Record>
    newPosDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
     
    GenericAppenderFactory
    set(String property, String value)
     
    GenericAppenderFactory
    setAll(Map<String,String> properties)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • GenericAppenderFactory

      public GenericAppenderFactory(org.apache.iceberg.Schema schema)

    • GenericAppenderFactory

      public GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec)

    • GenericAppenderFactory

      public GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema, org.apache.iceberg.Schema posDeleteRowSchema)

    • GenericAppenderFactory

      public GenericAppenderFactory(org.apache.iceberg.Table table, org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, Map<String,String> config, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema, org.apache.iceberg.Schema posDeleteRowSchema)
      Constructor for GenericAppenderFactory.
      Parameters:
      table - iceberg table
      schema - the schema of the records to write
      spec - the partition spec of the records
      config - the configuration for the writer
      equalityFieldIds - the field ids for equality delete
      eqDeleteRowSchema - the schema for equality delete rows
      posDeleteRowSchema - the schema for position delete rows

  • Method Details

    • set

      public GenericAppenderFactory set(String property, String value)

    • setAll

      public GenericAppenderFactory setAll(Map<String,String> properties)

    • newAppender

      public org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record> newAppender(org.apache.iceberg.io.OutputFile outputFile, org.apache.iceberg.FileFormat fileFormat)
      Specified by:
      newAppender in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>

    • newAppender

      public org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record> newAppender(org.apache.iceberg.encryption.EncryptedOutputFile encryptedOutputFile, org.apache.iceberg.FileFormat fileFormat)
      Specified by:
      newAppender in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>

    • newDataWriter

      public org.apache.iceberg.io.DataWriter<org.apache.iceberg.data.Record> newDataWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
      Specified by:
      newDataWriter in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>

    • newEqDeleteWriter

      public org.apache.iceberg.deletes.EqualityDeleteWriter<org.apache.iceberg.data.Record> newEqDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
      Specified by:
      newEqDeleteWriter in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>

    • newPosDeleteWriter

      public org.apache.iceberg.deletes.PositionDeleteWriter<org.apache.iceberg.data.Record> newPosDeleteWriter(org.apache.iceberg.encryption.EncryptedOutputFile file, org.apache.iceberg.FileFormat format, org.apache.iceberg.StructLike partition)
      Specified by:
      newPosDeleteWriter in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>