org.apache.paimon.table.source.snapshot

Interface StartingScanner

All Known Implementing Classes:

AbstractStartingScanner, CompactedStartingScanner, ContinuousCompactorStartingScanner, ContinuousFromSnapshotFullStartingScanner, ContinuousFromSnapshotStartingScanner, ContinuousFromTimestampStartingScanner, ContinuousLatestStartingScanner, FileCreationTimeStartingScanner, FullCompactedStartingScanner, FullStartingScanner, IncrementalStartingScanner, IncrementalTagStartingScanner, IncrementalTimeStampStartingScanner, ReadPlanStartingScanner, StaticFromSnapshotStartingScanner, StaticFromTagStartingScanner, StaticFromTimestampStartingScanner, StaticFromWatermarkStartingScanner

public interface StartingScanner

Helper class for the first planning of TableScan.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StartingScanner.NextSnapshot Return the next snapshot for followup scanning.
static class	StartingScanner.NoSnapshot Currently, there is no snapshot, need to wait for the snapshot to be generated.
static interface	StartingScanner.Result Scan result of scan(org.apache.paimon.table.source.snapshot.SnapshotReader).
static class	StartingScanner.ScannedResult Result with scanned snapshot.

Method Summary

Modifier and Type	Method and Description
static StartingScanner.ScannedResult	fromPlan(SnapshotReader.Plan plan)
StartingScanner.Result	scan(SnapshotReader snapshotReader)
List<PartitionEntry>	scanPartitions(SnapshotReader snapshotReader)
StartingContext	startingContext()

Method Detail

startingContext

StartingContext startingContext()

scan

StartingScanner.Result scan(SnapshotReader snapshotReader)

scanPartitions

List<PartitionEntry> scanPartitions(SnapshotReader snapshotReader)

fromPlan

static StartingScanner.ScannedResult fromPlan(SnapshotReader.Plan plan)