Package org.apache.iceberg.actions
Interface ActionsProvider
-
- All Known Implementing Classes:
SparkActions
public interface ActionsProvider
An API that should be implemented by query engine integrations for providing actions.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default ComputeTableStats
computeTableStats(Table table)
Instantiates an action to compute table stats.default DeleteOrphanFiles
deleteOrphanFiles(Table table)
Instantiates an action to delete orphan files.default DeleteReachableFiles
deleteReachableFiles(java.lang.String metadataLocation)
Instantiates an action to delete all the files reachable from given metadata location.default ExpireSnapshots
expireSnapshots(Table table)
Instantiates an action to expire snapshots.default MigrateTable
migrateTable(java.lang.String tableIdent)
Instantiates an action to migrate an existing table to Iceberg.default RemoveDanglingDeleteFiles
removeDanglingDeleteFiles(Table table)
Instantiates an action to remove dangling delete files from current snapshot.default RewriteDataFiles
rewriteDataFiles(Table table)
Instantiates an action to rewrite data files.default RewriteManifests
rewriteManifests(Table table)
Instantiates an action to rewrite manifests.default RewritePositionDeleteFiles
rewritePositionDeletes(Table table)
Instantiates an action to rewrite position delete filesdefault RewriteTablePath
rewriteTablePath(Table table)
Instantiates an action to rewrite all absolute paths in table metadata.default SnapshotTable
snapshotTable(java.lang.String sourceTableIdent)
Instantiates an action to snapshot an existing table as a new Iceberg table.
-
-
-
Method Detail
-
snapshotTable
default SnapshotTable snapshotTable(java.lang.String sourceTableIdent)
Instantiates an action to snapshot an existing table as a new Iceberg table.
-
migrateTable
default MigrateTable migrateTable(java.lang.String tableIdent)
Instantiates an action to migrate an existing table to Iceberg.
-
deleteOrphanFiles
default DeleteOrphanFiles deleteOrphanFiles(Table table)
Instantiates an action to delete orphan files.
-
rewriteManifests
default RewriteManifests rewriteManifests(Table table)
Instantiates an action to rewrite manifests.
-
rewriteDataFiles
default RewriteDataFiles rewriteDataFiles(Table table)
Instantiates an action to rewrite data files.
-
expireSnapshots
default ExpireSnapshots expireSnapshots(Table table)
Instantiates an action to expire snapshots.
-
deleteReachableFiles
default DeleteReachableFiles deleteReachableFiles(java.lang.String metadataLocation)
Instantiates an action to delete all the files reachable from given metadata location.
-
rewritePositionDeletes
default RewritePositionDeleteFiles rewritePositionDeletes(Table table)
Instantiates an action to rewrite position delete files
-
computeTableStats
default ComputeTableStats computeTableStats(Table table)
Instantiates an action to compute table stats.
-
rewriteTablePath
default RewriteTablePath rewriteTablePath(Table table)
Instantiates an action to rewrite all absolute paths in table metadata.
-
removeDanglingDeleteFiles
default RemoveDanglingDeleteFiles removeDanglingDeleteFiles(Table table)
Instantiates an action to remove dangling delete files from current snapshot.
-
-