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.

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.function.Predicate<FileStatus>	HIDDEN_PATH_FILTER

Constructor Summary

Constructors

Constructor and Description
HiveCloneUtils()

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	getDatabaseOptions(HiveCatalog hiveCatalog, String databaseName)
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)
static String	parseFormat(String serder)

Methods inherited from class java.lang.Object

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

Field Detail

HIDDEN_PATH_FILTER

public static final java.util.function.Predicate<FileStatus> HIDDEN_PATH_FILTER

Constructor Detail

HiveCloneUtils

public HiveCloneUtils()

Method Detail

getDatabaseOptions

public static Map<String,String> getDatabaseOptions(HiveCatalog hiveCatalog,
                                                    String databaseName)
                                             throws Exception

Throws:

Exception

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

parseFormat

public static String parseFormat(String serder)