Package | Description |
---|---|
org.apache.paimon.flink.clone | |
org.apache.paimon.hive.clone | |
org.apache.paimon.hudi |
Modifier and Type | Method and Description |
---|---|
static List<CloneFileInfo> |
CloneFileInfo.fromHive(Identifier identifier,
HivePartitionFiles files) |
Modifier and Type | Method and Description |
---|---|
List<HivePartitionFiles> |
HiveCloneExtractor.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) |
List<HivePartitionFiles> |
HiveTableCloneExtractor.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) |
static List<HivePartitionFiles> |
HiveCloneUtils.listFiles(HiveCatalog hiveCatalog,
Identifier identifier,
RowType partitionRowType,
String defaultPartitionName,
PartitionPredicate predicate) |
Modifier and Type | Method and Description |
---|---|
HivePartitionFiles |
HudiFileIndex.getUnpartitionedFiles(FileIO fileIO) |
Modifier and Type | Method and Description |
---|---|
List<HivePartitionFiles> |
HudiHiveCloneExtractor.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) |
List<HivePartitionFiles> |
HudiFileIndex.getAllFilteredPartitionFiles(FileIO fileIO) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.