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
Snapshotof 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 RowDeltaaddDeletes(DeleteFile deletes)Add aDeleteFileto the table.RowDeltaaddRows(DataFile inserts)Add aDataFileto 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 aDataFileto the table.- Parameters:
inserts- a data file of rows to insert- Returns:
- this for method chaining
-
addDeletes
RowDelta addDeletes(DeleteFile deletes)
Add aDeleteFileto the table.- Parameters:
deletes- a delete file of rows to delete- Returns:
- this for method chaining
-
-