org.apache.paimon.flink.lookup

Class LookupDataTableScan

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableScan

org.apache.paimon.table.source.DataTableStreamScan

org.apache.paimon.flink.lookup.LookupDataTableScan

All Implemented Interfaces:

DataTableScan, InnerTableScan, StreamDataTableScan, StreamTableScan, TableScan, Restorable<Long>

public class LookupDataTableScan
extends DataTableStreamScan

StreamTableScan implementation for lookup streaming planning.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.source.TableScan

TableScan.Plan

Field Summary

Fields inherited from class org.apache.paimon.table.source.AbstractDataTableScan

snapshotReader

Constructor Summary

Constructors

Constructor and Description
LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Method Summary

Modifier and Type	Method and Description
protected BoundedChecker	createBoundedChecker()
protected FollowUpScanner	createFollowUpScanner()
protected StartingScanner	createStartingScanner(boolean isStreaming)

Methods inherited from class org.apache.paimon.table.source.DataTableStreamScan

checkpoint, listPartitionEntries, notifyCheckpointComplete, plan, restore, restore, startingContext, watermark, withFilter, withShard

Methods inherited from class org.apache.paimon.table.source.AbstractDataTableScan

options, withBucket, withBucketFilter, withLevelFilter, withMetricsRegistry, withPartitionFilter, withPartitionFilter

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.table.source.InnerTableScan

withBucketFilter, withLevelFilter, withLimit, withMetricsRegistry, withPartitionFilter, withPartitionFilter

Methods inherited from interface org.apache.paimon.table.source.TableScan

listPartitions

Constructor Detail

LookupDataTableScan

public LookupDataTableScan(CoreOptions options,
                           SnapshotReader snapshotReader,
                           SnapshotManager snapshotManager,
                           boolean supportStreamingReadOverwrite,
                           DefaultValueAssigner defaultValueAssigner,
                           LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Method Detail

createStartingScanner

protected StartingScanner createStartingScanner(boolean isStreaming)

Overrides:

createStartingScanner in class AbstractDataTableScan

createFollowUpScanner

protected FollowUpScanner createFollowUpScanner()

Overrides:

createFollowUpScanner in class DataTableStreamScan

createBoundedChecker

protected BoundedChecker createBoundedChecker()

Overrides:

createBoundedChecker in class DataTableStreamScan