org.apache.paimon.hive.clone

Class HiveTableCloneExtractor

java.lang.Object

org.apache.paimon.hive.clone.HiveTableCloneExtractor

All Implemented Interfaces:

HiveCloneExtractor

Direct Known Subclasses:

HudiHiveCloneExtractor

public class HiveTableCloneExtractor
extends Object
implements HiveCloneExtractor

A HiveCloneExtractor for hive tables.

Field Summary

Fields

Modifier and Type	Field and Description
static HiveTableCloneExtractor	INSTANCE

Fields inherited from interface org.apache.paimon.hive.clone.HiveCloneExtractor

EXTRACTORS

Constructor Summary

Constructors

Constructor and Description
HiveTableCloneExtractor()

Method Summary

Modifier and Type	Method and Description
List<HivePartitionFiles>	extractFiles(Map<String,String> catalogOptions, org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.hive.metastore.api.Table table, FileIO fileIO, Identifier identifier, RowType partitionRowType, String defaultPartitionName, PartitionPredicate predicate)
Map<String,String>	extractOptions(org.apache.hadoop.hive.metastore.api.Table table)
List<String>	extractPartitionKeys(org.apache.hadoop.hive.metastore.api.Table table)
List<org.apache.hadoop.hive.metastore.api.FieldSchema>	extractSchema(org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.hive.metastore.api.Table hiveTable, String database, String table)
static Map<String,String>	getIdentifierPrefixOptions(String formatIdentifier, Map<String,String> options)
boolean	matches(org.apache.hadoop.hive.metastore.api.Table table)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.hive.clone.HiveCloneExtractor

getExtractor

Field Detail

INSTANCE

public static final HiveTableCloneExtractor INSTANCE

Constructor Detail

HiveTableCloneExtractor

public HiveTableCloneExtractor()

Method Detail

matches

public boolean matches(org.apache.hadoop.hive.metastore.api.Table table)

Specified by:

matches in interface HiveCloneExtractor

extractSchema

public List<org.apache.hadoop.hive.metastore.api.FieldSchema> extractSchema(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                                                            org.apache.hadoop.hive.metastore.api.Table hiveTable,
                                                                            String database,
                                                                            String table)
                                                                     throws Exception

Specified by:

extractSchema in interface HiveCloneExtractor

Throws:

Exception

extractFiles

public List<HivePartitionFiles> extractFiles(Map<String,String> catalogOptions,
                                             org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                             org.apache.hadoop.hive.metastore.api.Table table,
                                             FileIO fileIO,
                                             Identifier identifier,
                                             RowType partitionRowType,
                                             String defaultPartitionName,
                                             @Nullable
                                             PartitionPredicate predicate)
                                      throws Exception

Specified by:

extractFiles in interface HiveCloneExtractor

Throws:

Exception

extractPartitionKeys

public List<String> extractPartitionKeys(org.apache.hadoop.hive.metastore.api.Table table)

Specified by:

extractPartitionKeys in interface HiveCloneExtractor

extractOptions

public Map<String,String> extractOptions(org.apache.hadoop.hive.metastore.api.Table table)

Specified by:

extractOptions in interface HiveCloneExtractor

getIdentifierPrefixOptions

public static Map<String,String> getIdentifierPrefixOptions(String formatIdentifier,
                                                            Map<String,String> options)