Package org.apache.iceberg.io

Interface EqualityDeltaWriter<T>

Type Parameters:
T - the row type
All Superinterfaces:
AutoCloseable, Closeable
public interface EqualityDeltaWriter<T> extends Closeable
A writer capable of writing data and equality deletes that may belong to different specs and partitions.

  • Method Details

    • insert

      void insert(T row, PartitionSpec spec, StructLike partition)
      Inserts a row to the provided spec/partition.
      Parameters:
      row - a data record
      spec - a partition spec
      partition - a partition or null if the spec is unpartitioned

    • delete

      void delete(T row, PartitionSpec spec, StructLike partition)
      Deletes a row from the provided spec/partition.

      This method assumes the delete record has the same schema as the rows that will be inserted.

      Parameters:
      row - a delete record
      spec - a partition spec
      partition - a partition or null if the spec is unpartitioned

    • deleteKey

      void deleteKey(T key, PartitionSpec spec, StructLike partition)
      Deletes a key from the provided spec/partition.

      This method assumes the delete key contains values only for equality fields.

      Parameters:
      key - a delete key
      spec - a partition spec
      partition - a partition or null if the spec is unpartitioned

    • result

      WriteResult result()
      Returns a result that contains information about written DataFiles or DeleteFiles. The result is valid only after the writer is closed.
      Returns:
      the writer result