org.apache.paimon.table.source.snapshot

Class ReadPlanStartingScanner

java.lang.Object

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

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

All Implemented Interfaces:

StartingScanner

Direct Known Subclasses:

CompactedStartingScanner, ContinuousFromSnapshotFullStartingScanner, FileCreationTimeStartingScanner, FullCompactedStartingScanner, FullStartingScanner, StaticFromSnapshotStartingScanner, StaticFromTagStartingScanner, StaticFromTimestampStartingScanner, StaticFromWatermarkStartingScanner

public abstract class ReadPlanStartingScanner
extends AbstractStartingScanner

An AbstractStartingScanner to return plan.

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

Method Summary

Modifier and Type	Method and Description
protected abstract SnapshotReader	configure(SnapshotReader snapshotReader)
StartingScanner.Result	scan(SnapshotReader snapshotReader)
List<PartitionEntry>	scanPartitions(SnapshotReader snapshotReader)

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

Method Detail

configure

@Nullable
protected abstract SnapshotReader configure(SnapshotReader snapshotReader)

scan

public StartingScanner.Result scan(SnapshotReader snapshotReader)

scanPartitions

public List<PartitionEntry> scanPartitions(SnapshotReader snapshotReader)

Specified by:

scanPartitions in interface StartingScanner

Overrides:

scanPartitions in class AbstractStartingScanner