org.apache.paimon.hudi

Class HudiHiveCloneExtractor

java.lang.Object

org.apache.paimon.hive.clone.HiveTableCloneExtractor

org.apache.paimon.hudi.HudiHiveCloneExtractor

All Implemented Interfaces:

HiveCloneExtractor

public class HudiHiveCloneExtractor
extends HiveTableCloneExtractor

A HiveCloneExtractor for Hudi tables.

Field Summary

Fields inherited from class org.apache.paimon.hive.clone.HiveTableCloneExtractor

INSTANCE

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

EXTRACTORS

Constructor Summary

Constructors

Constructor and Description
HudiHiveCloneExtractor()

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)
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)
boolean	matches(org.apache.hadoop.hive.metastore.api.Table table)

Methods inherited from class org.apache.paimon.hive.clone.HiveTableCloneExtractor

extractOptions, extractPartitionKeys, getIdentifierPrefixOptions

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

Constructor Detail

HudiHiveCloneExtractor

public HudiHiveCloneExtractor()

Method Detail

matches

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

Specified by:

matches in interface HiveCloneExtractor

Overrides:

matches in class HiveTableCloneExtractor

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

Overrides:

extractSchema in class HiveTableCloneExtractor

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)

Specified by:

extractFiles in interface HiveCloneExtractor

Overrides:

extractFiles in class HiveTableCloneExtractor