Package org.apache.iceberg

Interface Transaction

All Known Implementing Classes:

BaseTransaction

public interface Transaction

A transaction for performing multiple updates to a table.

Method Summary

Modifier and Type	Method	Description
void	commitTransaction()	Apply the pending changes from all actions and commit.
ExpireSnapshots	expireSnapshots()	Create a new expire API to manage snapshots in this table.
default ManageSnapshots	manageSnapshots()	Create a new manage snapshot API to manage snapshots in this table.
AppendFiles	newAppend()	Create a new append API to add files to this table.
DeleteFiles	newDelete()	Create a new delete API to replace files in this table.
default AppendFiles	newFastAppend()	Create a new append API to add files to this table.
OverwriteFiles	newOverwrite()	Create a new overwrite API to overwrite files by a filter expression.
ReplacePartitions	newReplacePartitions()	Not recommended: Create a new replace partitions API to dynamically overwrite partitions in the table with new data.
RewriteFiles	newRewrite()	Create a new rewrite API to replace files in this table.
RowDelta	newRowDelta()	Create a new row-level delta API to remove or replace rows in existing data files.
ReplaceSortOrder	replaceSortOrder()	Create a new ReplaceSortOrder to set a table sort order and commit the change.
RewriteManifests	rewriteManifests()	Create a new rewrite manifests API to replace manifests for this table.
Table	table()	Return the Table that this transaction will update.
UpdateLocation	updateLocation()	Create a new UpdateLocation to update table location.
default UpdatePartitionStatistics	updatePartitionStatistics()	Create a new update partition statistics API to add or remove partition statistics files in this table.
UpdateProperties	updateProperties()	Create a new UpdateProperties to update table properties.
UpdateSchema	updateSchema()	Create a new UpdateSchema to alter the columns of this table.
UpdatePartitionSpec	updateSpec()	Create a new UpdatePartitionSpec to alter the partition spec of this table.
default UpdateStatistics	updateStatistics()	Create a new update table statistics API to add or remove statistics files in this table.

Method Details

table

Table table()

Return the Table that this transaction will update.

Returns:

this transaction's table

updateSchema

UpdateSchema updateSchema()

Create a new UpdateSchema to alter the columns of this table.

Returns:

a new UpdateSchema

updateSpec

UpdatePartitionSpec updateSpec()

Create a new UpdatePartitionSpec to alter the partition spec of this table.

Returns:

a new UpdatePartitionSpec

updateProperties

UpdateProperties updateProperties()

Create a new UpdateProperties to update table properties.

Returns:

a new UpdateProperties

replaceSortOrder

ReplaceSortOrder replaceSortOrder()

Create a new ReplaceSortOrder to set a table sort order and commit the change.

Returns:

a new ReplaceSortOrder

updateLocation

UpdateLocation updateLocation()

Create a new UpdateLocation to update table location.

Returns:

a new UpdateLocation

newAppend

AppendFiles newAppend()

Create a new append API to add files to this table.

Returns:

a new AppendFiles

newFastAppend

default AppendFiles newFastAppend()

Create a new append API to add files to this table.

Using this method signals to the underlying implementation that the append should not perform extra work in order to commit quickly. Fast appends are not recommended for normal writes because the fast commit may cause split planning to slow down over time.

Implementations may not support fast appends, in which case this will return the same appender as newAppend().

Returns:

a new AppendFiles

newRewrite

RewriteFiles newRewrite()

Create a new rewrite API to replace files in this table.

Returns:

a new RewriteFiles

rewriteManifests

RewriteManifests rewriteManifests()

Create a new rewrite manifests API to replace manifests for this table.

Returns:

a new RewriteManifests

newOverwrite

OverwriteFiles newOverwrite()

Create a new overwrite API to overwrite files by a filter expression.

Returns:

a new OverwriteFiles

newRowDelta

RowDelta newRowDelta()

Create a new row-level delta API to remove or replace rows in existing data files.

Returns:

a new RowDelta

newReplacePartitions

ReplacePartitions newReplacePartitions()

Not recommended: Create a new replace partitions API to dynamically overwrite partitions in the table with new data.

This is provided to implement SQL compatible with Hive table operations but is not recommended. Instead, use the overwrite API to explicitly overwrite data.

Returns:

a new ReplacePartitions

newDelete

DeleteFiles newDelete()

Create a new delete API to replace files in this table.

Returns:

a new DeleteFiles

updateStatistics

default UpdateStatistics updateStatistics()

Create a new update table statistics API to add or remove statistics files in this table.

Returns:

a new UpdateStatistics

updatePartitionStatistics

default UpdatePartitionStatistics updatePartitionStatistics()

Create a new update partition statistics API to add or remove partition statistics files in this table.

Returns:

a new UpdatePartitionStatistics

expireSnapshots

ExpireSnapshots expireSnapshots()

Create a new expire API to manage snapshots in this table.

Returns:

a new ExpireSnapshots

manageSnapshots

default ManageSnapshots manageSnapshots()

Create a new manage snapshot API to manage snapshots in this table.

Returns:

a new ManageSnapshots

commitTransaction

void commitTransaction()

Apply the pending changes from all actions and commit.

Throws:

ValidationException - If any update cannot be applied to the current table metadata.

CommitFailedException - If the updates cannot be committed due to conflicts.