public interface FileStoreScan
Modifier and Type | Interface and Description |
---|---|
static interface |
FileStoreScan.Plan
Result plan of this scan.
|
FileStoreScan withPartitionFilter(Predicate predicate)
FileStoreScan withPartitionFilter(List<BinaryRow> partitions)
FileStoreScan withPartitionFilter(PartitionPredicate predicate)
FileStoreScan withBucket(int bucket)
FileStoreScan withBucketFilter(Filter<Integer> bucketFilter)
FileStoreScan withTotalAwareBucketFilter(BiFilter<Integer,Integer> bucketFilter)
FileStoreScan withPartitionBucket(BinaryRow partition, int bucket)
FileStoreScan withSnapshot(long snapshotId)
FileStoreScan withSnapshot(Snapshot snapshot)
FileStoreScan withKind(ScanMode scanMode)
FileStoreScan withLevelFilter(Filter<Integer> levelFilter)
FileStoreScan enableValueFilter()
FileStoreScan withManifestEntryFilter(Filter<ManifestEntry> filter)
FileStoreScan withManifestCacheFilter(ManifestCacheFilter manifestFilter)
FileStoreScan withDataFileNameFilter(Filter<String> fileNameFilter)
FileStoreScan withMetrics(ScanMetrics metrics)
FileStoreScan dropStats()
ManifestsReader manifestsReader()
List<ManifestEntry> readManifest(ManifestFileMeta manifest)
FileStoreScan.Plan plan()
FileStoreScan.Plan
.default Long totalRecordCount(Snapshot snapshot)
List<SimpleFileEntry> readSimpleEntries()
SimpleFileEntry
s, SimpleFileEntry only retains some critical information, so it
cannot perform filtering based on statistical information.List<PartitionEntry> readPartitionEntries()
List<BucketEntry> readBucketEntries()
Iterator<ManifestEntry> readFileIterator()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.