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 Summary
All 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
- 
insert
void insert(T row, PartitionSpec spec, StructLike partition)
Inserts a row to the provided spec/partition.- Parameters:
 row- a data recordspec- a partition specpartition- 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 recordspec- a partition specpartition- 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 keyspec- a partition specpartition- a partition or null if the spec is unpartitioned
 
- 
result
WriteResult result()
Returns a result that contains information about writtenDataFiles orDeleteFiles. The result is valid only after the writer is closed.- Returns:
 - the writer result
 
 
 - 
 
 -