BaseTransaction

java.lang.Object
- org.apache.iceberg.BaseTransaction

All Implemented Interfaces:: Transaction

public class BaseTransaction
extends java.lang.Object
implements Transaction

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class BaseTransaction.TransactionTable

class BaseTransaction.TransactionTableOperations

Nested Classes
Modifier and Type	Class and Description
`class`	`BaseTransaction.TransactionTable`
`class`	`BaseTransaction.TransactionTableOperations`

Method Summary

All Methods Instance Methods Concrete Methods
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.
`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.
`TableMetadata`	`startMetadata()`
`Table`	`table()` Return the `Table` that this transaction will update.
`TableOperations`	`underlyingOps()`
`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.
`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 Detail
  - 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
  - startMetadata
```
public TableMetadata startMetadata()
```
  - underlyingOps
```
public TableOperations underlyingOps()
```
  - 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 and commit the change.
    
    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 replace 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
  - expireSnapshots
```
public ExpireSnapshots expireSnapshots()
```
    Description copied from interface: Transaction
    
    Create a new expire API to manage snapshots in this table.
    
    Specified by:
    
    expireSnapshots in interface Transaction
    
    Returns:
    
    a new ExpireSnapshots
  - commitTransaction
```
public void commitTransaction()
```
    Description copied from interface: Transaction
    
    Apply the pending changes from all actions and commit.
    
    Specified by:
    
    commitTransaction in interface Transaction

Class BaseTransaction

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

table

startMetadata

underlyingOps

updateSchema

updateSpec

updateProperties

replaceSortOrder

updateLocation

newAppend

newFastAppend

newRewrite

rewriteManifests

newOverwrite

newRowDelta

newReplacePartitions

newDelete

updateStatistics

expireSnapshots

commitTransaction