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

bucketKeyFilter, scanMode

Constructor Summary

Constructors

Constructor and Description

KeyValueFileStoreScan(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, KeyValueFieldsExtractor keyValueFieldsExtractor, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, boolean deletionVectorsEnabled, CoreOptions.MergeEngine mergeEngine, CoreOptions.ChangelogProducer changelogProducer)

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

plan, readAndMergeFileEntries, readBucketEntries, readPartitionEntries, readSimpleEntries, scanTableSchema, withBucket, withBucketFilter, withDataFileNameFilter, withKind, withLevelFilter, withManifestCacheFilter, withManifestEntryFilter, withManifestList, withMetrics, withPartitionBucket, withPartitionFilter, withPartitionFilter, withPartitionFilter, withSnapshot, withSnapshot

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(RowType partitionType,
                             ScanBucketFilter bucketFilter,
                             SnapshotManager snapshotManager,
                             SchemaManager schemaManager,
                             TableSchema schema,
                             KeyValueFieldsExtractor keyValueFieldsExtractor,
                             ManifestFile.Factory manifestFileFactory,
                             ManifestList.Factory manifestListFactory,
                             int numOfBuckets,
                             boolean checkNumOfBuckets,
                             Integer scanManifestParallelism,
                             boolean deletionVectorsEnabled,
                             CoreOptions.MergeEngine mergeEngine,
                             CoreOptions.ChangelogProducer changelogProducer)

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