Package org.apache.iceberg.io
Interface EqualityDeltaWriter<T>
- 
- Type Parameters:
- T- the row type
 - All Superinterfaces:
- java.lang.AutoCloseable,- java.io.Closeable
 
 public interface EqualityDeltaWriter<T> extends java.io.CloseableA writer capable of writing data and equality deletes that may belong to different specs and partitions.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description voiddelete(T row, PartitionSpec spec, StructLike partition)Deletes a row from the provided spec/partition.voiddeleteKey(T key, PartitionSpec spec, StructLike partition)Deletes a key from the provided spec/partition.voidinsert(T row, PartitionSpec spec, StructLike partition)Inserts a row to the provided spec/partition.WriteResultresult()Returns a result that contains information about writtenDataFiles orDeleteFiles.
 
- 
- 
- 
Method Detail- 
insertvoid 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
 
 - 
deletevoid 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
 
 - 
deleteKeyvoid 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
 
 - 
resultWriteResult result() Returns a result that contains information about writtenDataFiles orDeleteFiles. The result is valid only after the writer is closed.- Returns:
- the writer result
 
 
- 
 
-