org.apache.paimon.table.source.snapshot

Class StartingScanner.ScannedResult

java.lang.Object

org.apache.paimon.table.source.snapshot.StartingScanner.ScannedResult

All Implemented Interfaces:

StartingScanner.Result

Enclosing interface:

StartingScanner

public static class StartingScanner.ScannedResult
extends Object
implements StartingScanner.Result

Result with scanned snapshot. Next snapshot should be the current snapshot plus 1.

Constructor Summary

Constructors

Constructor and Description
ScannedResult(SnapshotReader.Plan plan)

Method Summary

Modifier and Type	Method and Description
long	currentSnapshotId()
Long	currentWatermark()
SnapshotReader.Plan	plan()
List<DataSplit>	splits()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScannedResult

public ScannedResult(SnapshotReader.Plan plan)

Method Detail

currentSnapshotId

public long currentSnapshotId()

currentWatermark

@Nullable
public Long currentWatermark()

splits

public List<DataSplit> splits()

plan

public SnapshotReader.Plan plan()