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

Modifier and Type	Method and Description
RowDelta	addDeletes(DeleteFile deletes) Add a DeleteFile to the table.
RowDelta	addRows(DataFile inserts) Add a DataFile to the table.

Methods inherited from interface org.apache.iceberg.SnapshotUpdate

deleteWith, set, stageOnly

Methods inherited from interface org.apache.iceberg.PendingUpdate

apply, commit, updateEvent

Method Detail

addRows

RowDelta addRows(DataFile inserts)

Add a DataFile to the table.

Parameters:

inserts - a data file of rows to insert

Returns:

this for method chaining

addDeletes

RowDelta addDeletes(DeleteFile deletes)

Add a DeleteFile to the table.

Parameters:

deletes - a delete file of rows to delete

Returns:

this for method chaining