org.apache.paimon.table.source.snapshot

Class StaticFromTimestampStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.ReadPlanStartingScanner

org.apache.paimon.table.source.snapshot.StaticFromTimestampStartingScanner

All Implemented Interfaces:

StartingScanner

public class StaticFromTimestampStartingScanner
extends ReadPlanStartingScanner

StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode 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
StaticFromTimestampStartingScanner(SnapshotManager snapshotManager, long startupMillis)

Method Summary

Modifier and Type	Method and Description
SnapshotReader	configure(SnapshotReader snapshotReader)
Snapshot	getSnapshot()
static Snapshot	timeTravelToTimestamp(SnapshotManager snapshotManager, long timestamp)

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

scan, scanPartitions

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

startingContext, 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

StaticFromTimestampStartingScanner

public StaticFromTimestampStartingScanner(SnapshotManager snapshotManager,
                                          long startupMillis)

Method Detail

getSnapshot

public Snapshot getSnapshot()

configure

public SnapshotReader configure(SnapshotReader snapshotReader)

Specified by:

configure in class ReadPlanStartingScanner

timeTravelToTimestamp

@Nullable
public static Snapshot timeTravelToTimestamp(SnapshotManager snapshotManager,
                                                       long timestamp)