public abstract class AbstractFileStoreScan extends Object implements FileStoreScan
FileStoreScan
.FileStoreScan.Plan
Constructor and Description |
---|
AbstractFileStoreScan(ManifestsReader manifestsReader,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer parallelism) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
listPartitions, totalRecordCount
protected ScanMode scanMode
public AbstractFileStoreScan(ManifestsReader manifestsReader, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, @Nullable Integer parallelism)
public FileStoreScan withPartitionFilter(Predicate predicate)
withPartitionFilter
in interface FileStoreScan
public FileStoreScan withPartitionFilter(List<BinaryRow> partitions)
withPartitionFilter
in interface FileStoreScan
public FileStoreScan withPartitionFilter(PartitionPredicate predicate)
withPartitionFilter
in interface FileStoreScan
public FileStoreScan withBucket(int bucket)
withBucket
in interface FileStoreScan
public FileStoreScan withBucketFilter(Filter<Integer> bucketFilter)
withBucketFilter
in interface FileStoreScan
public FileStoreScan withTotalAwareBucketFilter(BiFilter<Integer,Integer> totalAwareBucketFilter)
withTotalAwareBucketFilter
in interface FileStoreScan
public FileStoreScan withPartitionBucket(BinaryRow partition, int bucket)
withPartitionBucket
in interface FileStoreScan
public FileStoreScan withSnapshot(long snapshotId)
withSnapshot
in interface FileStoreScan
public FileStoreScan withSnapshot(Snapshot snapshot)
withSnapshot
in interface FileStoreScan
public FileStoreScan withKind(ScanMode scanMode)
withKind
in interface FileStoreScan
public FileStoreScan withLevelFilter(Filter<Integer> levelFilter)
withLevelFilter
in interface FileStoreScan
public FileStoreScan enableValueFilter()
enableValueFilter
in interface FileStoreScan
public FileStoreScan withManifestEntryFilter(Filter<ManifestEntry> filter)
withManifestEntryFilter
in interface FileStoreScan
public FileStoreScan withManifestCacheFilter(ManifestCacheFilter manifestFilter)
withManifestCacheFilter
in interface FileStoreScan
public FileStoreScan withDataFileNameFilter(Filter<String> fileNameFilter)
withDataFileNameFilter
in interface FileStoreScan
public FileStoreScan withMetrics(ScanMetrics metrics)
withMetrics
in interface FileStoreScan
public FileStoreScan dropStats()
dropStats
in interface FileStoreScan
@Nullable public Integer parallelism()
parallelism
in interface FileStoreScan
public ManifestsReader manifestsReader()
manifestsReader
in interface FileStoreScan
public FileStoreScan.Plan plan()
FileStoreScan
FileStoreScan.Plan
.plan
in interface FileStoreScan
public List<SimpleFileEntry> readSimpleEntries()
FileStoreScan
SimpleFileEntry
s, SimpleFileEntry only retains some critical information, so it
cannot perform filtering based on statistical information.readSimpleEntries
in interface FileStoreScan
public List<PartitionEntry> readPartitionEntries()
readPartitionEntries
in interface FileStoreScan
public List<BucketEntry> readBucketEntries()
readBucketEntries
in interface FileStoreScan
public Iterator<ManifestEntry> readFileIterator()
readFileIterator
in interface FileStoreScan
protected TableSchema scanTableSchema(long id)
protected abstract boolean filterByStats(ManifestEntry entry)
protected boolean wholeBucketFilterEnabled()
protected List<ManifestEntry> filterWholeBucketByStats(List<ManifestEntry> entries)
public List<ManifestEntry> readManifest(ManifestFileMeta manifest)
readManifest
in interface FileStoreScan
protected ManifestEntry dropStats(ManifestEntry entry)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.