org.apache.paimon.iceberg.migrate

Class IcebergMigrator

java.lang.Object

org.apache.paimon.iceberg.migrate.IcebergMigrator

All Implemented Interfaces:

Migrator

public class IcebergMigrator
extends Object
implements Migrator

migrate iceberg table to paimon table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergMigrator.MigrateTask One import task for one partition.

Constructor Summary

Constructors

Constructor and Description
IcebergMigrator(Catalog paimonCatalog, String paimonDatabaseName, String paimonTableName, String icebergDatabaseName, String icebergTableName, Options icebergOptions, Integer parallelism)

Method Summary

Modifier and Type	Method and Description
void	deleteOriginTable(boolean delete)
void	executeMigrate()
Schema	icebergSchemaToPaimonSchema(IcebergMetadata icebergMetadata)
void	renameTable(boolean ignoreIfNotExists)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IcebergMigrator

public IcebergMigrator(Catalog paimonCatalog,
                       String paimonDatabaseName,
                       String paimonTableName,
                       String icebergDatabaseName,
                       String icebergTableName,
                       Options icebergOptions,
                       Integer parallelism)

Method Detail

executeMigrate

public void executeMigrate()
                    throws Exception

Specified by:

executeMigrate in interface Migrator

Throws:

Exception

deleteOriginTable

public void deleteOriginTable(boolean delete)
                       throws Exception

Specified by:

deleteOriginTable in interface Migrator

Throws:

Exception

renameTable

public void renameTable(boolean ignoreIfNotExists)
                 throws Exception

Specified by:

renameTable in interface Migrator

Throws:

Exception

icebergSchemaToPaimonSchema

public Schema icebergSchemaToPaimonSchema(IcebergMetadata icebergMetadata)