public abstract class AbstractDataTableScan extends Object implements DataTableScan
FileStoreScan
to provide input split generation.TableScan.Plan
Modifier and Type | Field and Description |
---|---|
protected SnapshotReader |
snapshotReader |
Modifier | Constructor and Description |
---|---|
protected |
AbstractDataTableScan(CoreOptions options,
SnapshotReader snapshotReader) |
Modifier and Type | Method and Description |
---|---|
protected StartingScanner |
createStartingScanner(boolean isStreaming) |
AbstractDataTableScan |
dropStats() |
CoreOptions |
options() |
AbstractDataTableScan |
withBucket(int bucket) |
AbstractDataTableScan |
withBucketFilter(Filter<Integer> bucketFilter) |
AbstractDataTableScan |
withLevelFilter(Filter<Integer> levelFilter) |
AbstractDataTableScan |
withMetricsRegistry(MetricRegistry metricsRegistry) |
AbstractDataTableScan |
withPartitionFilter(List<BinaryRow> partitions) |
AbstractDataTableScan |
withPartitionFilter(Map<String,String> partitionSpec) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withShard
withFilter, withLimit
listPartitionEntries, listPartitions, plan
protected final SnapshotReader snapshotReader
protected AbstractDataTableScan(CoreOptions options, SnapshotReader snapshotReader)
@VisibleForTesting public AbstractDataTableScan withBucket(int bucket)
public AbstractDataTableScan withBucketFilter(Filter<Integer> bucketFilter)
withBucketFilter
in interface InnerTableScan
public AbstractDataTableScan withPartitionFilter(Map<String,String> partitionSpec)
withPartitionFilter
in interface InnerTableScan
public AbstractDataTableScan withPartitionFilter(List<BinaryRow> partitions)
withPartitionFilter
in interface InnerTableScan
public AbstractDataTableScan withLevelFilter(Filter<Integer> levelFilter)
withLevelFilter
in interface InnerTableScan
public AbstractDataTableScan withMetricsRegistry(MetricRegistry metricsRegistry)
withMetricsRegistry
in interface InnerTableScan
public AbstractDataTableScan dropStats()
dropStats
in interface InnerTableScan
public CoreOptions options()
protected StartingScanner createStartingScanner(boolean isStreaming)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.