Package org.apache.iceberg.delta
Interface SnapshotDeltaLakeTable
-
- All Superinterfaces:
Action<SnapshotDeltaLakeTable,SnapshotDeltaLakeTable.Result>
public interface SnapshotDeltaLakeTable extends Action<SnapshotDeltaLakeTable,SnapshotDeltaLakeTable.Result>
Snapshot an existing Delta Lake table to Iceberg in place.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
SnapshotDeltaLakeTable.Result
The action result that contains a summary of the execution.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description SnapshotDeltaLakeTable
as(TableIdentifier identifier)
Sets the identifier of the newly created Iceberg table.SnapshotDeltaLakeTable
deltaLakeConfiguration(org.apache.hadoop.conf.Configuration conf)
Sets the Hadoop configuration used to access delta lake table's logs and datafiles.SnapshotDeltaLakeTable
icebergCatalog(Catalog catalog)
Sets the catalog of the newly created Iceberg table.SnapshotDeltaLakeTable
tableLocation(java.lang.String location)
Sets the location of the newly created Iceberg table.SnapshotDeltaLakeTable
tableProperties(java.util.Map<java.lang.String,java.lang.String> properties)
Sets table properties in the newly created Iceberg table.SnapshotDeltaLakeTable
tableProperty(java.lang.String name, java.lang.String value)
Sets a table property in the newly created Iceberg table.
-
-
-
Method Detail
-
tableProperties
SnapshotDeltaLakeTable tableProperties(java.util.Map<java.lang.String,java.lang.String> properties)
Sets table properties in the newly created Iceberg table. Any properties with the same key name will be overwritten.- Parameters:
properties
- a map of properties to set- Returns:
- this for method chaining
-
tableProperty
SnapshotDeltaLakeTable tableProperty(java.lang.String name, java.lang.String value)
Sets a table property in the newly created Iceberg table. Any properties with the same key will be overwritten.- Parameters:
name
- a table property namevalue
- a table property value- Returns:
- this for method chaining
-
tableLocation
SnapshotDeltaLakeTable tableLocation(java.lang.String location)
Sets the location of the newly created Iceberg table. Default location is the same as the Delta Lake table.- Parameters:
location
- a path to the new table location- Returns:
- this for method chaining
-
as
SnapshotDeltaLakeTable as(TableIdentifier identifier)
Sets the identifier of the newly created Iceberg table. This is required to be set before execute the action.- Parameters:
identifier
- a table identifier (namespace, name) @Returns this for method chaining
-
icebergCatalog
SnapshotDeltaLakeTable icebergCatalog(Catalog catalog)
Sets the catalog of the newly created Iceberg table. This is required to be set before execute the action- Parameters:
catalog
- a catalog @Returns this for method chaining
-
deltaLakeConfiguration
SnapshotDeltaLakeTable deltaLakeConfiguration(org.apache.hadoop.conf.Configuration conf)
Sets the Hadoop configuration used to access delta lake table's logs and datafiles. This is required to be set before execute the action.- Parameters:
conf
- a Hadoop configuration @Returns this for method chaining
-
-