org.apache.paimon.table.source.snapshot

Class ContinuousFromTimestampStartingScanner

java.lang.Object

org.apache.paimon.table.source.snapshot.AbstractStartingScanner

org.apache.paimon.table.source.snapshot.ContinuousFromTimestampStartingScanner

All Implemented Interfaces:

StartingScanner

public class ContinuousFromTimestampStartingScanner
extends AbstractStartingScanner

StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode of a streaming read.

Nested Class Summary

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

StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult

Field Summary

Fields inherited from class org.apache.paimon.table.source.snapshot.AbstractStartingScanner

snapshotManager, startingSnapshotId

Constructor Summary

Constructors

Constructor and Description
ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager, ChangelogManager changelogManager, long startupMillis, boolean changelogDecoupled)

Method Summary

Modifier and Type	Method and Description
StartingScanner.Result	scan(SnapshotReader snapshotReader)
StartingContext	startingContext()

Methods inherited from class org.apache.paimon.table.source.snapshot.AbstractStartingScanner

scanPartitions, startingScanMode

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.snapshot.StartingScanner

fromPlan

Constructor Detail

ContinuousFromTimestampStartingScanner

public ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager,
                                              ChangelogManager changelogManager,
                                              long startupMillis,
                                              boolean changelogDecoupled)

Method Detail

startingContext

public StartingContext startingContext()

Specified by:

startingContext in interface StartingScanner

Overrides:

startingContext in class AbstractStartingScanner

scan

public StartingScanner.Result scan(SnapshotReader snapshotReader)