Package org.apache.iceberg.delta

Interface SnapshotDeltaLakeTable

All Superinterfaces:

Action<SnapshotDeltaLakeTable,SnapshotDeltaLakeTable.Result>

@Enclosing
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

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.

Methods inherited from interface org.apache.iceberg.actions.Action

execute, option, options

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 name

value - 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