org.apache.paimon.operation

Class KeyValueFileStoreScan

java.lang.Object

org.apache.paimon.operation.AbstractFileStoreScan

org.apache.paimon.operation.KeyValueFileStoreScan

All Implemented Interfaces:

FileStoreScan

public class KeyValueFileStoreScan
extends AbstractFileStoreScan

FileStoreScan for KeyValueFileStore.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.operation.FileStoreScan

FileStoreScan.Plan

Field Summary

Fields inherited from class org.apache.paimon.operation.AbstractFileStoreScan

scanMode

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class org.apache.paimon.operation.AbstractFileStoreScan

dropStats, manifestsReader, onlyReadRealBuckets, parallelism, plan, readBucketEntries, readFileIterator, readManifest, readPartitionEntries, readSimpleEntries, scanTableSchema, withBucket, withBucketFilter, withDataFileNameFilter, withKind, withLevel, withLevelFilter, withManifestCacheFilter, withManifestEntryFilter, withMetrics, withPartitionBucket, withPartitionFilter, withPartitionFilter, withPartitionFilter, withPartitionsFilter, withSnapshot, withSnapshot, withTotalAwareBucketFilter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.operation.FileStoreScan

listPartitions, totalRecordCount

Constructor Detail

KeyValueFileStoreScan

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)

Method Detail

withKeyFilter

public KeyValueFileStoreScan withKeyFilter(Predicate predicate)

withValueFilter

public KeyValueFileStoreScan withValueFilter(Predicate predicate)

enableValueFilter

public FileStoreScan enableValueFilter()

Specified by:

enableValueFilter in interface FileStoreScan

Overrides:

enableValueFilter in class AbstractFileStoreScan

filterByStats

protected boolean filterByStats(ManifestEntry entry)

Note: Keep this thread-safe.

Specified by:

filterByStats in class AbstractFileStoreScan

dropStats

protected ManifestEntry dropStats(ManifestEntry entry)

Overrides:

dropStats in class AbstractFileStoreScan

wholeBucketFilterEnabled

protected boolean wholeBucketFilterEnabled()

Overrides:

wholeBucketFilterEnabled in class AbstractFileStoreScan

filterWholeBucketByStats

protected List<ManifestEntry> filterWholeBucketByStats(List<ManifestEntry> entries)

Overrides:

filterWholeBucketByStats in class AbstractFileStoreScan