org.apache.iceberg

Interface Transaction

public interface Transaction

A transaction for performing multiple updates to a table.

Method Summary

Modifier and Type	Method and 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.
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.
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.
UpdateProperties	updateProperties() Create a new UpdateProperties to update table properties.
UpdateSchema	updateSchema() Create a new UpdateSchema to alter the columns of this table.

Method Detail

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

updateProperties

UpdateProperties updateProperties()

Create a new UpdateProperties to update table properties.

Returns:

a new UpdateProperties

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

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

expireSnapshots

ExpireSnapshots expireSnapshots()

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

Returns:

a new ExpireSnapshots

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.