Package | Description |
---|---|
org.apache.paimon.flink.clone.hive | |
org.apache.paimon.hive.migrate |
Modifier and Type | Field and Description |
---|---|
protected HiveCatalog |
CopyProcessFunction.hiveCatalog |
Modifier and Type | Method and Description |
---|---|
static HiveCatalog |
CloneHiveUtils.getRootHiveCatalog(Catalog catalog) |
Modifier and Type | Method and Description |
---|---|
static List<Migrator> |
HiveMigrator.databaseMigrators(HiveCatalog hiveCatalog,
String sourceDatabase,
Map<String,String> options,
Integer parallelism) |
static Schema |
HiveCloneUtils.hiveTableToPaimonSchema(HiveCatalog hiveCatalog,
Identifier identifier) |
static List<HivePartitionFiles> |
HiveCloneUtils.listFiles(HiveCatalog hiveCatalog,
Identifier identifier,
RowType partitionRowType,
String defaultPartitionName,
PartitionPredicate predicate) |
static List<Identifier> |
HiveCloneUtils.listTables(HiveCatalog hiveCatalog) |
static List<Identifier> |
HiveCloneUtils.listTables(HiveCatalog hiveCatalog,
String database) |
Constructor and Description |
---|
HiveMigrator(HiveCatalog hiveCatalog,
String sourceDatabase,
String sourceTable,
String targetDatabase,
String targetTable,
Integer parallelism,
Map<String,String> options) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.