Package org.apache.iceberg
Interface RowDelta
-
- All Superinterfaces:
PendingUpdate<Snapshot>
,SnapshotUpdate<RowDelta>
- All Known Implementing Classes:
BaseRowDelta
public interface RowDelta extends SnapshotUpdate<RowDelta>
API for encoding row-level changes to a table.This API accumulates data and delete file changes, produces a new
Snapshot
of the table, and commits that snapshot as the current.When committing, these changes will be applied to the latest table snapshot. Commit conflicts will be resolved by applying the changes to the new latest snapshot and reattempting the commit.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RowDelta
addDeletes(DeleteFile deletes)
Add aDeleteFile
to the table.RowDelta
addRows(DataFile inserts)
Add aDataFile
to the table.-
Methods inherited from interface org.apache.iceberg.PendingUpdate
apply, commit, updateEvent
-
Methods inherited from interface org.apache.iceberg.SnapshotUpdate
deleteWith, set, stageOnly
-
-
-
-
Method Detail
-
addRows
RowDelta addRows(DataFile inserts)
Add aDataFile
to the table.- Parameters:
inserts
- a data file of rows to insert- Returns:
- this for method chaining
-
addDeletes
RowDelta addDeletes(DeleteFile deletes)
Add aDeleteFile
to the table.- Parameters:
deletes
- a delete file of rows to delete- Returns:
- this for method chaining
-
-