org.apache.paimon.table.source

Interface StreamDataTableScan

All Superinterfaces:

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

All Known Implementing Classes:

DataTableStreamScan, LookupDataTableScan

public interface StreamDataTableScan
extends DataTableScan, StreamTableScan

Streaming InnerTableScan with StreamTableScan.

Nested Class Summary

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

TableScan.Plan

Method Summary

Modifier and Type	Method and Description
void	restore(Long nextSnapshotId, boolean scanAllSnapshot) Restore from checkpoint next snapshot id with scan kind.
StartingContext	startingContext()

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

withShard

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

dropStats, withBucket, withBucketFilter, withFilter, withLevelFilter, withLimit, withMetricRegistry, withPartitionFilter, withPartitionFilter, withPartitionsFilter, withReadType

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

listPartitionEntries, listPartitions, plan

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

checkpoint, notifyCheckpointComplete, restore, watermark

Method Detail

startingContext

StartingContext startingContext()

restore

void restore(@Nullable
             Long nextSnapshotId,
             boolean scanAllSnapshot)

Restore from checkpoint next snapshot id with scan kind.