Interface MigrateTable

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