Package org.apache.iceberg

Class BaseTransaction

java.lang.Object

org.apache.iceberg.BaseTransaction

All Implemented Interfaces:

Transaction

public class BaseTransaction
extends Object
implements Transaction

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BaseTransaction.TransactionTable
class	BaseTransaction.TransactionTableOperations

Method Summary

Modifier and Type	Method	Description
protected final <T extends PendingUpdate> T	appendUpdate(T update)
void	commitTransaction()	Apply the pending changes from all actions and commit.
TableMetadata	currentMetadata()
ExpireSnapshots	expireSnapshots()	Create a new expire API to expire snapshots in this table.
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 delete files in this table.
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.
RewriteManifests	rewriteManifests()	Create a new rewrite manifests API to replace manifests for this table.
TableMetadata	startMetadata()
Table	table()	Return the Table that this transaction will update.
String	tableName()
TableOperations	underlyingOps()
UpdateLocation	updateLocation()	Create a new UpdateLocation to update table location.
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.
UpdateStatistics	updateStatistics()	Create a new update table statistics API to add or remove statistics files in this table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

table

public Table table()

Description copied from interface: Transaction

Return the Table that this transaction will update.

Specified by:

table in interface Transaction

Returns:

this transaction's table

tableName

public String tableName()

startMetadata

public TableMetadata startMetadata()

currentMetadata

public TableMetadata currentMetadata()

underlyingOps

public TableOperations underlyingOps()

appendUpdate

protected final <T extends PendingUpdate> T appendUpdate(T update)

updateSchema

public UpdateSchema updateSchema()

Description copied from interface: Transaction

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

Specified by:

updateSchema in interface Transaction

Returns:

a new UpdateSchema

updateSpec

public UpdatePartitionSpec updateSpec()

Description copied from interface: Transaction

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

Specified by:

updateSpec in interface Transaction

Returns:

a new UpdatePartitionSpec

updateProperties

public UpdateProperties updateProperties()

Description copied from interface: Transaction

Create a new UpdateProperties to update table properties.

Specified by:

updateProperties in interface Transaction

Returns:

a new UpdateProperties

replaceSortOrder

public ReplaceSortOrder replaceSortOrder()

Description copied from interface: Transaction

Create a new ReplaceSortOrder to set a table sort order.

Specified by:

replaceSortOrder in interface Transaction

Returns:

a new ReplaceSortOrder

updateLocation

public UpdateLocation updateLocation()

Description copied from interface: Transaction

Create a new UpdateLocation to update table location.

Specified by:

updateLocation in interface Transaction

Returns:

a new UpdateLocation

newAppend

public AppendFiles newAppend()

Description copied from interface: Transaction

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

Specified by:

newAppend in interface Transaction

Returns:

a new AppendFiles

newFastAppend

public AppendFiles newFastAppend()

Description copied from interface: Transaction

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 Transaction.newAppend().

Specified by:

newFastAppend in interface Transaction

Returns:

a new AppendFiles

newRewrite

public RewriteFiles newRewrite()

Description copied from interface: Transaction

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

Specified by:

newRewrite in interface Transaction

Returns:

a new RewriteFiles

rewriteManifests

public RewriteManifests rewriteManifests()

Description copied from interface: Transaction

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

Specified by:

rewriteManifests in interface Transaction

Returns:

a new RewriteManifests

newOverwrite

public OverwriteFiles newOverwrite()

Description copied from interface: Transaction

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

Specified by:

newOverwrite in interface Transaction

Returns:

a new OverwriteFiles

newRowDelta

public RowDelta newRowDelta()

Description copied from interface: Transaction

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

Specified by:

newRowDelta in interface Transaction

Returns:

a new RowDelta

newReplacePartitions

public ReplacePartitions newReplacePartitions()

Description copied from interface: Transaction

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.

Specified by:

newReplacePartitions in interface Transaction

Returns:

a new ReplacePartitions

newDelete

public DeleteFiles newDelete()

Description copied from interface: Transaction

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

Specified by:

newDelete in interface Transaction

Returns:

a new DeleteFiles

updateStatistics

public UpdateStatistics updateStatistics()

Description copied from interface: Transaction

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

Specified by:

updateStatistics in interface Transaction

Returns:

a new UpdateStatistics

updatePartitionStatistics

public UpdatePartitionStatistics updatePartitionStatistics()

Description copied from interface: Transaction

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

Specified by:

updatePartitionStatistics in interface Transaction

Returns:

a new UpdatePartitionStatistics

expireSnapshots

public ExpireSnapshots expireSnapshots()

Description copied from interface: Transaction

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

Specified by:

expireSnapshots in interface Transaction

Returns:

a new ExpireSnapshots

manageSnapshots

public ManageSnapshots manageSnapshots()

Description copied from interface: Transaction

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

Specified by:

manageSnapshots in interface Transaction

Returns:

a new ManageSnapshots

commitTransaction

public void commitTransaction()

Description copied from interface: Transaction

Apply the pending changes from all actions and commit.

Specified by:

commitTransaction in interface Transaction