Package | Description |
---|---|
org.apache.paimon.flink.utils | |
org.apache.paimon.hive.migrate | |
org.apache.paimon.spark.utils |
Modifier and Type | Method and Description |
---|---|
static Migrator |
TableMigrationUtils.getImporter(String connector,
Catalog catalog,
String sourceDatabase,
String sourceTableName,
String targetDatabase,
String targetTableName,
Integer parallelism,
Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
static List<Migrator> |
TableMigrationUtils.getImporters(String connector,
Catalog catalog,
String sourceDatabase,
Integer parallelism,
Map<String,String> options) |
Modifier and Type | Class and Description |
---|---|
class |
HiveMigrator
Migrate hive table to paimon table.
|
Modifier and Type | Method and Description |
---|---|
static List<Migrator> |
HiveMigrator.databaseMigrators(HiveCatalog hiveCatalog,
String sourceDatabase,
Map<String,String> options,
Integer parallelism) |
Modifier and Type | Method and Description |
---|---|
static Migrator |
TableMigrationUtils.getImporter(String connector,
Catalog catalog,
String sourceDatabase,
String sourceTableName,
String targetDatabase,
String targetTableName,
Integer parallelism,
Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
static List<Migrator> |
TableMigrationUtils.getImporters(String connector,
Catalog catalog,
String sourceDatabase,
Integer parallelism,
Map<String,String> options) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.