Package org.apache.iceberg.actions
Interface MigrateTable
-
- All Superinterfaces:
Action<MigrateTable,MigrateTable.Result>
- All Known Implementing Classes:
MigrateTableSparkAction
public interface MigrateTable extends Action<MigrateTable,MigrateTable.Result>
An action that migrates an existing table to Iceberg.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
MigrateTable.Result
The action result that contains a summary of the execution.
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default MigrateTable
backupTableName(java.lang.String tableName)
Sets a table name for the backup of the original table.default MigrateTable
dropBackup()
Drops the backup of the original table after a successful migrationdefault MigrateTable
executeWith(java.util.concurrent.ExecutorService service)
Sets the executor service to use for parallel file reading.MigrateTable
tableProperties(java.util.Map<java.lang.String,java.lang.String> properties)
Sets table properties in the newly created Iceberg table.MigrateTable
tableProperty(java.lang.String name, java.lang.String value)
Sets a table property in the newly created Iceberg table.
-
-
-
Method Detail
-
tableProperties
MigrateTable 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
MigrateTable 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
-
dropBackup
default MigrateTable dropBackup()
Drops the backup of the original table after a successful migration- Returns:
- this for method chaining
-
backupTableName
default MigrateTable backupTableName(java.lang.String tableName)
Sets a table name for the backup of the original table.- Parameters:
tableName
- the table name for backup- Returns:
- this for method chaining
-
executeWith
default MigrateTable executeWith(java.util.concurrent.ExecutorService service)
Sets the executor service to use for parallel file reading. The default is not using executor service.- Parameters:
service
- executor service- Returns:
- this for method chaining
-
-