org.apache.paimon.table.source.snapshot

Class IncrementalStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.IncrementalStartingScanner

All Implemented Interfaces:

StartingScanner

public class IncrementalStartingScanner
extends AbstractStartingScanner

StartingScanner for incremental changes by snapshot.

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
IncrementalStartingScanner(SnapshotManager snapshotManager, long start, long end, ScanMode scanMode)

Method Summary

Modifier and Type	Method and Description
Optional<StartingScanner.Result>	checkScanSnapshotIdValidity() Check the validity of staring snapshotId early.
StartingScanner.Result	scan(SnapshotReader reader)

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

IncrementalStartingScanner

public IncrementalStartingScanner(SnapshotManager snapshotManager,
                                  long start,
                                  long end,
                                  ScanMode scanMode)

Method Detail

scan

public StartingScanner.Result scan(SnapshotReader reader)

checkScanSnapshotIdValidity

public Optional<StartingScanner.Result> checkScanSnapshotIdValidity()

Check the validity of staring snapshotId early.

Returns:

If the check passes return empty.