ComputeTableStatsSparkAction |
Computes the statistics of the given columns and stores it as Puffin files.
|
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 |
A serializable bean that contains a bare minimum to read a manifest.
|
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.
|
NDVSketchUtil |
|
RewriteDataFilesSparkAction |
|
RewriteManifestsSparkAction |
An action that rewrites manifests in a distributed manner and co-locates metadata for partitions.
|
RewritePositionDeleteFilesSparkAction |
|
SetAccumulator<T> |
|
SnapshotTableSparkAction |
Creates a new Iceberg table based on a source Spark table.
|
SparkActions |
|