public class AppendOnlyFileStoreScan extends AbstractFileStoreScan
FileStoreScan.Plan
scanMode
Constructor and Description |
---|
AppendOnlyFileStoreScan(ManifestsReader manifestsReader,
BucketSelectConverter bucketSelectConverter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer scanManifestParallelism,
boolean fileIndexReadEnabled) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
filterByStats(ManifestEntry entry)
Note: Keep this thread-safe.
|
protected List<ManifestEntry> |
filterWholeBucketByStats(List<ManifestEntry> entries)
Note: Keep this thread-safe.
|
AppendOnlyFileStoreScan |
withFilter(Predicate predicate) |
manifestsReader, parallelism, plan, readAndMergeFileEntries, readBucketEntries, readFileIterator, readManifest, readPartitionEntries, readSimpleEntries, scanTableSchema, withBucket, withBucketFilter, withDataFileNameFilter, withKind, withLevelFilter, withManifestCacheFilter, withManifestEntryFilter, withManifestList, withMetrics, withPartitionBucket, withPartitionFilter, withPartitionFilter, withPartitionFilter, withSnapshot, withSnapshot, withTotalAwareBucketFilter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
listPartitions, totalRecordCount
public AppendOnlyFileStoreScan(ManifestsReader manifestsReader, BucketSelectConverter bucketSelectConverter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, Integer scanManifestParallelism, boolean fileIndexReadEnabled)
public AppendOnlyFileStoreScan withFilter(Predicate predicate)
protected boolean filterByStats(ManifestEntry entry)
filterByStats
in class AbstractFileStoreScan
protected List<ManifestEntry> filterWholeBucketByStats(List<ManifestEntry> entries)
AbstractFileStoreScan
filterWholeBucketByStats
in class AbstractFileStoreScan
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.