Uses of Interface
org.apache.paimon.table.source.StreamTableScan

Packages that use StreamTableScan

Package	Description
org.apache.paimon.flink.compact
org.apache.paimon.flink.lookup
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.table.source

Uses of StreamTableScan in org.apache.paimon.flink.compact

Fields in org.apache.paimon.flink.compact with type parameters of type StreamTableScan

Modifier and Type	Field and Description
protected Map<Identifier,StreamTableScan>	MultiAwareBucketTableScan.scansMap

Uses of StreamTableScan in org.apache.paimon.flink.lookup

Classes in org.apache.paimon.flink.lookup that implement StreamTableScan

Modifier and Type	Class and Description
class	LookupDataTableScan StreamTableScan implementation for lookup streaming planning.

Uses of StreamTableScan in org.apache.paimon.flink.source

Fields in org.apache.paimon.flink.source declared as StreamTableScan

Modifier and Type	Field and Description
protected StreamTableScan	ContinuousFileSplitEnumerator.scan

Methods in org.apache.paimon.flink.source with parameters of type StreamTableScan

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)

Constructors in org.apache.paimon.flink.source with parameters of type StreamTableScan

Constructor and Description
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, int splitMaxPerTask, boolean shuffleBucketWithPartition)

Uses of StreamTableScan in org.apache.paimon.flink.source.align

Methods in org.apache.paimon.flink.source.align with parameters of type StreamTableScan

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	AlignedContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)

Constructors in org.apache.paimon.flink.source.align with parameters of type StreamTableScan

Constructor and Description
AlignedContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, long alignTimeout, int splitPerTaskMax, boolean shuffleBucketWithPartition)

Uses of StreamTableScan in org.apache.paimon.table.source

Subinterfaces of StreamTableScan in org.apache.paimon.table.source

Modifier and Type	Interface and Description
interface	StreamDataTableScan Streaming InnerTableScan with StreamTableScan.

Classes in org.apache.paimon.table.source that implement StreamTableScan

Modifier and Type	Class and Description
class	DataTableStreamScan StreamTableScan implementation for streaming planning.

Methods in org.apache.paimon.table.source that return StreamTableScan

Modifier and Type	Method and Description
StreamTableScan	ReadBuilderImpl.newStreamScan()
StreamTableScan	ReadBuilder.newStreamScan() Create a TableScan to perform streaming planning.