Package | Description |
---|---|
org.apache.paimon.hive.clone | |
org.apache.paimon.hudi | |
org.apache.paimon.operation | |
org.apache.paimon.partition |
Modifier and Type | Method and Description |
---|---|
List<HivePartitionFiles> |
HiveCloneExtractor.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<HivePartitionFiles> |
HiveTableCloneExtractor.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) |
static List<HivePartitionFiles> |
HiveCloneUtils.listFiles(HiveCatalog hiveCatalog,
Identifier identifier,
RowType partitionRowType,
String defaultPartitionName,
PartitionPredicate predicate) |
Modifier and Type | Method and Description |
---|---|
List<HivePartitionFiles> |
HudiHiveCloneExtractor.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) |
Constructor and Description |
---|
HudiFileIndex(String location,
Map<String,String> tableOptions,
Map<String,String> catalogOptions,
RowType partitionType,
PartitionPredicate partitionPredicate) |
Modifier and Type | Method and Description |
---|---|
PartitionPredicate |
ManifestsReader.partitionFilter() |
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
FileStoreScan.withPartitionFilter(PartitionPredicate predicate) |
FileStoreScan |
AbstractFileStoreScan.withPartitionFilter(PartitionPredicate predicate) |
ManifestsReader |
ManifestsReader.withPartitionFilter(PartitionPredicate predicate) |
Modifier and Type | Class and Description |
---|---|
static class |
PartitionPredicate.DefaultPartitionPredicate
A
PartitionPredicate using Predicate . |
static class |
PartitionPredicate.MultiplePartitionPredicate
A
PartitionPredicate optimizing for multiple partitions. |
Modifier and Type | Method and Description |
---|---|
static PartitionPredicate |
PartitionPredicate.alwaysFalse() |
static PartitionPredicate |
PartitionPredicate.alwaysTrue() |
static PartitionPredicate |
PartitionPredicate.fromMultiple(RowType partitionType,
List<BinaryRow> partitions) |
static PartitionPredicate |
PartitionPredicate.fromMultiple(RowType partitionType,
Set<BinaryRow> partitions) |
static PartitionPredicate |
PartitionPredicate.fromPredicate(RowType partitionType,
Predicate predicate)
Compared to the multiple method, this approach can accept filtering of partially partitioned
fields.
|
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.