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	getImporter(String connector, Catalog catalog, String sourceDatabase, String souceTableName, String targetDatabase, String targetTableName, Map<String,String> options)
static List<Migrator>	getImporters(String connector, Catalog catalog, String sourceDatabase, 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 souceTableName,
                                   String targetDatabase,
                                   String targetTableName,
                                   Map<String,String> options)

getImporters

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