public class KeyValueFileStoreScan extends AbstractFileStoreScan
FileStoreScan.Plan
bucketKeyType
Constructor and Description |
---|
KeyValueFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType keyType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
KeyValueFieldsExtractor keyValueFieldsExtractor,
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.
|
KeyValueFileStoreScan |
withKeyFilter(Predicate predicate) |
plan, scanTableSchema, scanTableSchema, withBucket, withBucketKeyFilter, withKind, withLevel, withManifestList, withPartitionFilter, withPartitionFilter, withSnapshot
public KeyValueFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType, org.apache.flink.table.types.logical.RowType bucketKeyType, org.apache.flink.table.types.logical.RowType keyType, SnapshotManager snapshotManager, SchemaManager schemaManager, long schemaId, KeyValueFieldsExtractor keyValueFieldsExtractor, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets)
public KeyValueFileStoreScan withKeyFilter(Predicate predicate)
protected boolean filterByStats(ManifestEntry entry)
filterByStats
in class AbstractFileStoreScan
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.