org.apache.paimon.hive.clone

Interface HiveCloneExtractor

All Known Implementing Classes:

HiveTableCloneExtractor, HudiHiveCloneExtractor

public interface HiveCloneExtractor

An interface for hive clone schema and files extractor.

Field Summary

Fields

Modifier and Type	Field and Description
static List<HiveCloneExtractor>	EXTRACTORS

Method Summary

Modifier and Type	Method and Description
List<HivePartitionFiles>	extractFiles(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 HiveCloneExtractor	getExtractor(org.apache.hadoop.hive.metastore.api.Table table)
boolean	matches(org.apache.hadoop.hive.metastore.api.Table table)

Field Detail

EXTRACTORS

static final List<HiveCloneExtractor> EXTRACTORS

Method Detail

matches

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

extractSchema

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

Throws:

Exception

extractFiles

List<HivePartitionFiles> extractFiles(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

Throws:

Exception

extractPartitionKeys

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

extractOptions

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

getExtractor

static HiveCloneExtractor getExtractor(org.apache.hadoop.hive.metastore.api.Table table)