org.apache.paimon.operation

Class AppendOnlyFileStoreScan

java.lang.Object

org.apache.paimon.operation.AbstractFileStoreScan

org.apache.paimon.operation.AppendOnlyFileStoreScan

All Implemented Interfaces:

FileStoreScan

public class AppendOnlyFileStoreScan
extends AbstractFileStoreScan

FileStoreScan for AppendOnlyFileStore.

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
AppendOnlyFileStoreScan(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, 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.
AppendOnlyFileStoreScan	withFilter(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

AppendOnlyFileStoreScan

public AppendOnlyFileStoreScan(RowType partitionType,
                               ScanBucketFilter bucketFilter,
                               SnapshotManager snapshotManager,
                               SchemaManager schemaManager,
                               TableSchema schema,
                               ManifestFile.Factory manifestFileFactory,
                               ManifestList.Factory manifestListFactory,
                               int numOfBuckets,
                               boolean checkNumOfBuckets,
                               Integer scanManifestParallelism,
                               boolean fileIndexReadEnabled)

Method Detail

withFilter

public AppendOnlyFileStoreScan withFilter(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)

Description copied from class: AbstractFileStoreScan

Note: Keep this thread-safe.

Specified by:

filterWholeBucketByStats in class AbstractFileStoreScan