public class LookupDataTableScan extends DataTableStreamScan
StreamTableScan
implementation for lookup streaming
planning.TableScan.Plan
snapshotReader
Constructor and Description |
---|
LookupDataTableScan(CoreOptions options,
SnapshotReader snapshotReader,
SnapshotManager snapshotManager,
boolean supportStreamingReadOverwrite,
DefaultValueAssigner defaultValueAssigner,
LookupFileStoreTable.LookupStreamScanMode lookupScanMode) |
Modifier and Type | Method and Description |
---|---|
protected BoundedChecker |
createBoundedChecker() |
protected FollowUpScanner |
createFollowUpScanner() |
protected StartingScanner |
createStartingScanner(boolean isStreaming) |
checkpoint, listPartitionEntries, notifyCheckpointComplete, plan, restore, restore, startingContext, watermark, withFilter, withShard
options, withBucket, withBucketFilter, withLevelFilter, withMetricsRegistry, withPartitionFilter, withPartitionFilter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withBucketFilter, withLevelFilter, withLimit, withMetricsRegistry, withPartitionFilter, withPartitionFilter
listPartitions
public LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)
protected StartingScanner createStartingScanner(boolean isStreaming)
createStartingScanner
in class AbstractDataTableScan
protected FollowUpScanner createFollowUpScanner()
createFollowUpScanner
in class DataTableStreamScan
protected BoundedChecker createBoundedChecker()
createBoundedChecker
in class DataTableStreamScan
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.