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 boolean	filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected List<ManifestEntry>	filterWholeBucketByStats(List<ManifestEntry> entries) Note: Keep this thread-safe.
KeyValueFileStoreScan	withKeyFilter(Predicate predicate)
KeyValueFileStoreScan	withValueFilter(Predicate predicate)

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

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

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)

filterByStats

protected boolean filterByStats(ManifestEntry entry)

Note: Keep this thread-safe.

Specified by:

filterByStats in class AbstractFileStoreScan

filterWholeBucketByStats

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

Note: Keep this thread-safe.

Specified by:

filterWholeBucketByStats in class AbstractFileStoreScan