org.apache.paimon.table.source.snapshot

Class ContinuousFromSnapshotFullStartingScanner

java.lang.Object

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

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

org.apache.paimon.table.source.snapshot.ContinuousFromSnapshotFullStartingScanner

All Implemented Interfaces:

StartingScanner

public class ContinuousFromSnapshotFullStartingScanner
extends ReadPlanStartingScanner

StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT_FULL 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
ContinuousFromSnapshotFullStartingScanner(SnapshotManager snapshotManager, long snapshotId)

Method Summary

Modifier and Type	Method and Description
SnapshotReader	configure(SnapshotReader snapshotReader)
ScanMode	startingScanMode()

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

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

ContinuousFromSnapshotFullStartingScanner

public ContinuousFromSnapshotFullStartingScanner(SnapshotManager snapshotManager,
                                                 long snapshotId)

Method Detail

startingScanMode

public ScanMode startingScanMode()

Overrides:

startingScanMode in class AbstractStartingScanner

configure

public SnapshotReader configure(SnapshotReader snapshotReader)

Specified by:

configure in class ReadPlanStartingScanner