public class AppendOnlyFileStoreScan extends AbstractFileStoreScan
FileStoreScan.Plan
bucketKeyType
Constructor and Description |
---|
AppendOnlyFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType rowType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
filterByStats(ManifestEntry entry)
Note: Keep this thread-safe.
|
AppendOnlyFileStoreScan |
withFilter(Predicate predicate) |
plan, scanTableSchema, scanTableSchema, withBucket, withBucketKeyFilter, withKind, withLevel, withManifestList, withPartitionFilter, withPartitionFilter, withSnapshot
public AppendOnlyFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType, org.apache.flink.table.types.logical.RowType bucketKeyType, org.apache.flink.table.types.logical.RowType rowType, SnapshotManager snapshotManager, SchemaManager schemaManager, long schemaId, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets)
public AppendOnlyFileStoreScan withFilter(Predicate predicate)
protected boolean filterByStats(ManifestEntry entry)
filterByStats
in class AbstractFileStoreScan
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.