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>
@Deprecated public class GenericAppenderFactory extends Object implements org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>
Deprecated.
will be removed in 1.12.0; use GenericFileWriterFactory instead.
Factory to create a new FileAppender to write Records.

  • Constructor Summary

    Constructors
    Constructor
    Description
    GenericAppenderFactory(org.apache.iceberg.Schema schema)
    Deprecated.
     
    GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec)
    Deprecated.
     
    GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema)
    Deprecated.
    Constructor for GenericAppenderFactory.
    GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema, org.apache.iceberg.Schema posDeleteRowSchema)
    Deprecated.
     
    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)
    Deprecated.
    Constructor for GenericAppenderFactory.
    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)
    Deprecated.
    This constructor is deprecated as of version 1.11.0 and will be removed in 1.12.0.

  • 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)
    Deprecated.
     
    org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record>
    newAppender(org.apache.iceberg.io.OutputFile outputFile, org.apache.iceberg.FileFormat fileFormat)
    Deprecated.
     
    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)
    Deprecated.
     
    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)
    Deprecated.
     
    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)
    Deprecated.
     
    GenericAppenderFactory
    set(String property, String value)
    Deprecated.
     
    GenericAppenderFactory
    setAll(Map<String,String> properties)
    Deprecated.
     

    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)
      Deprecated.

    • GenericAppenderFactory

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

    • 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)
      Deprecated.

    • GenericAppenderFactory

      public GenericAppenderFactory(org.apache.iceberg.Schema schema, org.apache.iceberg.PartitionSpec spec, int[] equalityFieldIds, org.apache.iceberg.Schema eqDeleteRowSchema)
      Deprecated.
      Constructor for GenericAppenderFactory.
      Parameters:
      schema - the schema of the records to write
      spec - the partition spec of the records
      equalityFieldIds - the field ids for equality delete
      eqDeleteRowSchema - the schema for equality delete rows

    • 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)
      Deprecated.
      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

    • GenericAppenderFactory

      @Deprecated 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)
      Deprecated.
      This constructor is deprecated as of version 1.11.0 and will be removed in 1.12.0. Position deletes that include row data are no longer supported. Use GenericAppenderFactory(Table, Schema, PartitionSpec, Map, int[], Schema) instead.
      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)
      Deprecated.

    • setAll

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

    • newAppender

      public org.apache.iceberg.io.FileAppender<org.apache.iceberg.data.Record> newAppender(org.apache.iceberg.io.OutputFile outputFile, org.apache.iceberg.FileFormat fileFormat)
      Deprecated.
      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)
      Deprecated.
      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)
      Deprecated.
      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)
      Deprecated.
      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)
      Deprecated.
      Specified by:
      newPosDeleteWriter in interface org.apache.iceberg.io.FileAppenderFactory<org.apache.iceberg.data.Record>