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