Interface EqualityDeltaWriter<T>

  • Type Parameters:
    T - the row type
    All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable

    public interface EqualityDeltaWriter<T>
    extends java.io.Closeable
    A writer capable of writing data and equality deletes that may belong to different specs and partitions.
    • Method Detail

      • 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