org.apache.paimon.hive.migrate

Class HiveCloneUtils

java.lang.Object

org.apache.paimon.hive.migrate.HiveCloneUtils

public class HiveCloneUtils
extends Object

Utils for cloning Hive table to Paimon table.

Constructor Summary

Constructors

Constructor and Description
HiveCloneUtils()

Method Summary

Modifier and Type	Method and Description
static Schema	hiveTableToPaimonSchema(HiveCatalog hiveCatalog, Identifier identifier)
static List<HivePartitionFiles>	listFiles(HiveCatalog hiveCatalog, Identifier identifier, RowType partitionRowType, String defaultPartitionName, PartitionPredicate predicate)
static List<Identifier>	listTables(HiveCatalog hiveCatalog)
static List<Identifier>	listTables(HiveCatalog hiveCatalog, String database)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveCloneUtils

public HiveCloneUtils()

Method Detail

listTables

public static List<Identifier> listTables(HiveCatalog hiveCatalog)
                                   throws Exception

Throws:

Exception

listTables

public static List<Identifier> listTables(HiveCatalog hiveCatalog,
                                          String database)
                                   throws Exception

Throws:

Exception

hiveTableToPaimonSchema

public static Schema hiveTableToPaimonSchema(HiveCatalog hiveCatalog,
                                             Identifier identifier)
                                      throws Exception

Throws:

Exception

listFiles

public static List<HivePartitionFiles> listFiles(HiveCatalog hiveCatalog,
                                                 Identifier identifier,
                                                 RowType partitionRowType,
                                                 String defaultPartitionName,
                                                 @Nullable
                                                 PartitionPredicate predicate)
                                          throws Exception

Throws:

Exception