| Class | Description |
|---|---|
| DeleteOrphanFilesSparkAction |
An action that removes orphan metadata, data and delete files by listing a given location and
comparing the actual files in that location with content and metadata files referenced by all
valid snapshots.
|
| DeleteOrphanFilesSparkAction.FileURI | |
| DeleteReachableFilesSparkAction |
An implementation of
DeleteReachableFiles that uses metadata tables in Spark to determine
which files should be deleted. |
| ExpireSnapshotsSparkAction |
An action that performs the same operation as
ExpireSnapshots but uses
Spark to determine the delta in files between the pre and post-expiration table metadata. |
| FileInfo | |
| ManifestFileBean | |
| MigrateTableSparkAction |
Takes a Spark table in the source catalog and attempts to transform it into an Iceberg table in
the same location with the same identifier.
|
| RewriteDataFilesSparkAction | |
| RewriteManifestsSparkAction |
An action that rewrites manifests in a distributed manner and co-locates metadata for partitions.
|
| RewritePositionDeleteFilesSparkAction |
Spark implementation of
RewritePositionDeleteFiles. |
| SetAccumulator<T> | |
| SnapshotTableSparkAction |
Creates a new Iceberg table based on a source Spark table.
|
| SparkActions |
An implementation of
ActionsProvider for Spark. |