org.apache.paimon.flink.utils

Class TableMigrationUtils

java.lang.Object

org.apache.paimon.flink.utils.TableMigrationUtils

public class TableMigrationUtils
extends Object

Migration util to choose importer according to connector.

Constructor Summary

Constructors

Constructor and Description
TableMigrationUtils()

Method Summary

Modifier and Type	Method and Description
static Migrator	getIcebergImporter(Catalog catalog, String sourceDatabase, String sourceTableName, String targetDatabase, String targetTableName, Integer parallelism, Map<String,String> options, Map<String,String> icebergOptions)
static Migrator	getImporter(String connector, Catalog catalog, String sourceDatabase, String sourceTableName, String targetDatabase, String targetTableName, Integer parallelism, Map<String,String> options)
static List<Migrator>	getImporters(String connector, Catalog catalog, String sourceDatabase, Integer parallelism, Map<String,String> options)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableMigrationUtils

public TableMigrationUtils()

Method Detail

getImporter

public static Migrator getImporter(String connector,
                                   Catalog catalog,
                                   String sourceDatabase,
                                   String sourceTableName,
                                   String targetDatabase,
                                   String targetTableName,
                                   Integer parallelism,
                                   Map<String,String> options)

getIcebergImporter

public static Migrator getIcebergImporter(Catalog catalog,
                                          String sourceDatabase,
                                          String sourceTableName,
                                          String targetDatabase,
                                          String targetTableName,
                                          Integer parallelism,
                                          Map<String,String> options,
                                          Map<String,String> icebergOptions)

getImporters

public static List<Migrator> getImporters(String connector,
                                          Catalog catalog,
                                          String sourceDatabase,
                                          Integer parallelism,
                                          Map<String,String> options)