org.apache.iceberg.actions

Class Actions

java.lang.Object

org.apache.iceberg.actions.Actions

public class Actions
extends java.lang.Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Actions(org.apache.spark.sql.SparkSession spark, Table table)

Method Summary

Modifier and Type	Method and Description
ExpireSnapshotsAction	expireSnapshots()
static Actions	forTable(org.apache.spark.sql.SparkSession spark, Table table)
static Actions	forTable(Table table)
static CreateAction	migrate(org.apache.spark.sql.SparkSession spark, java.lang.String tableName) Converts the provided table into an Iceberg table in place.
static CreateAction	migrate(java.lang.String tableName) Converts the provided table into an Iceberg table in place.
RemoveOrphanFilesAction	removeOrphanFiles()
RewriteDataFilesAction	rewriteDataFiles()
RewriteManifestsAction	rewriteManifests()
static SnapshotAction	snapshot(org.apache.spark.sql.SparkSession spark, java.lang.String sourceTable, java.lang.String destTable) Creates an independent Iceberg table based on a given table.
static SnapshotAction	snapshot(java.lang.String sourceTable, java.lang.String destTable) Creates an independent Iceberg table based on a given table.
protected org.apache.spark.sql.SparkSession	spark()
protected Table	table()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Actions

protected Actions(org.apache.spark.sql.SparkSession spark,
                  Table table)

Method Detail

forTable

public static Actions forTable(org.apache.spark.sql.SparkSession spark,
                               Table table)

forTable

public static Actions forTable(Table table)

removeOrphanFiles

public RemoveOrphanFilesAction removeOrphanFiles()

rewriteManifests

public RewriteManifestsAction rewriteManifests()

rewriteDataFiles

public RewriteDataFilesAction rewriteDataFiles()

expireSnapshots

public ExpireSnapshotsAction expireSnapshots()

migrate

public static CreateAction migrate(java.lang.String tableName)

Converts the provided table into an Iceberg table in place. The table will no longer be accessible by it's previous implementation

Parameters:

tableName - Table to be converted

Returns:

CreateAction to perform migration

migrate

public static CreateAction migrate(org.apache.spark.sql.SparkSession spark,
                                   java.lang.String tableName)

Converts the provided table into an Iceberg table in place. The table will no longer be accessible by it's previous implementation

Parameters:

tableName - Table to be converted

spark - Spark session to use for looking up table

Returns:

CreateAction to perform migration

snapshot

public static SnapshotAction snapshot(org.apache.spark.sql.SparkSession spark,
                                      java.lang.String sourceTable,
                                      java.lang.String destTable)

Creates an independent Iceberg table based on a given table. The new Iceberg table can be altered, appended or deleted without causing any change to the original. New data and metadata will be created in the default location for tables of this name in the destination catalog.

Parameters:

sourceTable - Original table which is the basis for the new Iceberg table

destTable - New Iceberg table being created

Returns:

SnapshotAction to perform snapshot

snapshot

public static SnapshotAction snapshot(java.lang.String sourceTable,
                                      java.lang.String destTable)

Creates an independent Iceberg table based on a given table. The new Iceberg table can be altered, appended or deleted without causing any change to the original. New data and metadata will be created in the default location for tables of this name in the destination catalog.

Parameters:

sourceTable - Original table which is the basis for the new Iceberg table

destTable - New Iceberg table being created

Returns:

SnapshotAction to perform snapshot

spark

protected org.apache.spark.sql.SparkSession spark()

table

protected Table table()