Modifier and Type | Field and Description |
---|---|
protected org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Identifier,List<PartitionEntry>> |
CachingCatalog.partitionCache |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
DelegateCatalog.listPartitions(Identifier identifier) |
List<PartitionEntry> |
Catalog.listPartitions(Identifier identifier)
Get PartitionEntry of all partitions of the table.
|
List<PartitionEntry> |
AbstractCatalog.listPartitions(Identifier identifier) |
List<PartitionEntry> |
CachingCatalog.listPartitions(Identifier identifier) |
Modifier and Type | Method and Description |
---|---|
static PartitionEntry |
PartitionEntry.fromDataFile(BinaryRow partition,
FileKind kind,
DataFileMeta file) |
static PartitionEntry |
PartitionEntry.fromManifestEntry(ManifestEntry entry) |
PartitionEntry |
PartitionEntry.merge(PartitionEntry entry) |
Modifier and Type | Method and Description |
---|---|
static Collection<PartitionEntry> |
PartitionEntry.merge(Collection<ManifestEntry> fileEntries) |
static Collection<PartitionEntry> |
PartitionEntry.mergeSplits(Collection<DataSplit> splits) |
Modifier and Type | Method and Description |
---|---|
PartitionEntry |
PartitionEntry.merge(PartitionEntry entry) |
Modifier and Type | Method and Description |
---|---|
static void |
PartitionEntry.merge(Collection<PartitionEntry> from,
Map<BinaryRow,PartitionEntry> to) |
static void |
PartitionEntry.merge(Collection<PartitionEntry> from,
Map<BinaryRow,PartitionEntry> to) |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
FileStoreScan.readPartitionEntries() |
List<PartitionEntry> |
AbstractFileStoreScan.readPartitionEntries() |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
PartitionValuesTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
List<PartitionEntry> |
PartitionUpdateTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
abstract List<PartitionEntry> |
PartitionExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
TableScan.listPartitionEntries() |
List<PartitionEntry> |
DataTableStreamScan.listPartitionEntries() |
List<PartitionEntry> |
ReadOnceTableScan.listPartitionEntries() |
List<PartitionEntry> |
DataTableBatchScan.listPartitionEntries() |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
SnapshotReader.partitionEntries() |
List<PartitionEntry> |
SnapshotReaderImpl.partitionEntries() |
List<PartitionEntry> |
StartingScanner.scanPartitions(SnapshotReader snapshotReader) |
List<PartitionEntry> |
ReadPlanStartingScanner.scanPartitions(SnapshotReader snapshotReader) |
List<PartitionEntry> |
AbstractStartingScanner.scanPartitions(SnapshotReader snapshotReader) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.