T - the row typepublic interface EqualityDeltaWriter<T>
extends java.io.Closeable
| Modifier and Type | Method and Description |
|---|---|
void |
delete(T row,
PartitionSpec spec,
StructLike partition)
Deletes a row from the provided spec/partition.
|
void |
deleteKey(T key,
PartitionSpec spec,
StructLike partition)
Deletes a key from the provided spec/partition.
|
void |
insert(T row,
PartitionSpec spec,
StructLike partition)
Inserts a row to the provided spec/partition.
|
WriteResult |
result()
Returns a result that contains information about written
DataFiles or DeleteFiles. |
void insert(T row, PartitionSpec spec, StructLike partition)
row - a data recordspec - a partition specpartition - a partition or null if the spec is unpartitionedvoid delete(T row, PartitionSpec spec, StructLike partition)
This method assumes the delete record has the same schema as the rows that will be inserted.
row - a delete recordspec - a partition specpartition - a partition or null if the spec is unpartitionedvoid deleteKey(T key, PartitionSpec spec, StructLike partition)
This method assumes the delete key contains values only for equality fields.
key - a delete keyspec - a partition specpartition - a partition or null if the spec is unpartitionedWriteResult result()
DataFiles or DeleteFiles.
The result is valid only after the writer is closed.