Class ClusteredEqualityDeleteWriter<T>

  • All Implemented Interfaces:, java.lang.AutoCloseable, PartitioningWriter<T,​DeleteWriteResult>

    public class ClusteredEqualityDeleteWriter<T>
    extends java.lang.Object
    An equality delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
    • Method Detail

      • write

        public void write​(T row,
                          PartitionSpec spec,
                          StructLike partition)
        Description copied from interface: PartitioningWriter
        Writes a row to the provided spec/partition.
        Specified by:
        write in interface PartitioningWriter<T,​R>
        row - a data or delete record
        spec - a partition spec
        partition - a partition or null if the spec is unpartitioned
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface
      • result

        public final R result()
        Description copied from interface: PartitioningWriter
        Returns a result that contains information about written DataFiles or DeleteFiles. The result is valid only after the writer is closed.
        Specified by:
        result in interface PartitioningWriter<T,​R>
        the writer result