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
DataFile s or DeleteFile s. |
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()
DataFile
s or DeleteFile
s.
The result is valid only after the writer is closed.