Modifier and Type | Class and Description |
---|---|
static class |
HiveMigrator.MigrateTask
One import task for one partition.
|
Constructor and Description |
---|
HiveMigrator(HiveCatalog hiveCatalog,
String sourceDatabase,
String sourceTable,
String targetDatabase,
String targetTable,
Integer parallelism,
Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
static List<Migrator> |
databaseMigrators(HiveCatalog hiveCatalog,
String sourceDatabase,
Map<String,String> options,
Integer parallelism) |
void |
deleteOriginTable(boolean deleteOriginTable) |
void |
executeMigrate() |
Schema |
from(List<org.apache.hadoop.hive.metastore.api.FieldSchema> fields,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionFields,
Map<String,String> hiveTableOptions) |
HiveMigrator.MigrateTask |
importUnPartitionedTableTask(FileIO fileIO,
org.apache.hadoop.hive.metastore.api.Table sourceTable,
FileStoreTable paimonTable,
Map<Path,Path> rollback) |
void |
renameTable(boolean ignoreIfNotExists) |
public static List<Migrator> databaseMigrators(HiveCatalog hiveCatalog, String sourceDatabase, Map<String,String> options, Integer parallelism)
public void deleteOriginTable(boolean deleteOriginTable)
deleteOriginTable
in interface Migrator
public void executeMigrate() throws Exception
executeMigrate
in interface Migrator
Exception
public void renameTable(boolean ignoreIfNotExists) throws Exception
renameTable
in interface Migrator
Exception
public Schema from(List<org.apache.hadoop.hive.metastore.api.FieldSchema> fields, List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionFields, Map<String,String> hiveTableOptions)
public HiveMigrator.MigrateTask importUnPartitionedTableTask(FileIO fileIO, org.apache.hadoop.hive.metastore.api.Table sourceTable, FileStoreTable paimonTable, Map<Path,Path> rollback)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.