Package org.apache.iceberg.actions
Interface ActionsProvider
-
- All Known Implementing Classes:
SparkActions
public interface ActionsProviderAn 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 ComputeTableStatscomputeTableStats(Table table)Instantiates an action to compute table stats.default DeleteOrphanFilesdeleteOrphanFiles(Table table)Instantiates an action to delete orphan files.default DeleteReachableFilesdeleteReachableFiles(java.lang.String metadataLocation)Instantiates an action to delete all the files reachable from given metadata location.default ExpireSnapshotsexpireSnapshots(Table table)Instantiates an action to expire snapshots.default MigrateTablemigrateTable(java.lang.String tableIdent)Instantiates an action to migrate an existing table to Iceberg.default RemoveDanglingDeleteFilesremoveDanglingDeleteFiles(Table table)Instantiates an action to remove dangling delete files from current snapshot.default RewriteDataFilesrewriteDataFiles(Table table)Instantiates an action to rewrite data files.default RewriteManifestsrewriteManifests(Table table)Instantiates an action to rewrite manifests.default RewritePositionDeleteFilesrewritePositionDeletes(Table table)Instantiates an action to rewrite position delete filesdefault RewriteTablePathrewriteTablePath(Table table)Instantiates an action to rewrite all absolute paths in table metadata.default SnapshotTablesnapshotTable(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.
-
-