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.
  • Method Details

    • tableProperties

      SnapshotDeltaLakeTable tableProperties(Map<String,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(String name, 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(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

      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