org.apache.paimon.table.source.snapshot

Class StaticFromWatermarkStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.StaticFromWatermarkStartingScanner

All Implemented Interfaces:

StartingScanner

public class StaticFromWatermarkStartingScanner
extends AbstractStartingScanner

StartingScanner for the CoreOptions.SCAN_WATERMARK of a batch 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
StaticFromWatermarkStartingScanner(SnapshotManager snapshotManager, long watermark)

Method Summary

Modifier and Type	Method and Description
StartingScanner.Result	scan(SnapshotReader snapshotReader)
ScanMode	startingScanMode()
static Snapshot	timeTravelToWatermark(SnapshotManager snapshotManager, long watermark)

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

startingContext

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

StaticFromWatermarkStartingScanner

public StaticFromWatermarkStartingScanner(SnapshotManager snapshotManager,
                                          long watermark)

Method Detail

startingScanMode

public ScanMode startingScanMode()

Overrides:

startingScanMode in class AbstractStartingScanner

scan

public StartingScanner.Result scan(SnapshotReader snapshotReader)

timeTravelToWatermark

@Nullable
public static Snapshot timeTravelToWatermark(SnapshotManager snapshotManager,
                                                       long watermark)