Package org.apache.paimon.table.source.snapshot

Interface Summary

Interface	Description
BoundedChecker	Checker to check whether the bounded stream is end.
FollowUpScanner	Helper class for the follow-up planning of StreamTableScan.
SnapshotReader	Read splits from specified Snapshot with given configuration.
SnapshotReader.Plan	Result plan of this scan.
StartingScanner	Helper class for the first planning of TableScan.
StartingScanner.Result	Scan result of StartingScanner.scan(org.apache.paimon.table.source.snapshot.SnapshotReader).

Class Summary

Class	Description
AbstractStartingScanner	The abstract class for StartingScanner.
AllDeltaFollowUpScanner	FollowUpScanner for read all file changes.
CompactedStartingScanner	StartingScanner for the CoreOptions.StartupMode#COMPACTED_FULL startup mode.
CompactionChangelogFollowUpScanner	FollowUpScanner for CoreOptions.ChangelogProducer#FULL_COMPACTION changelog producer.
ContinuousCompactorStartingScanner	StartingScanner used internally for stand-alone streaming compact job sources.
ContinuousFromSnapshotFullStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT_FULL startup mode of a batch read.
ContinuousFromSnapshotStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT startup mode of a streaming read.
ContinuousFromTimestampStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode of a streaming read.
ContinuousLatestStartingScanner	StartingScanner for the CoreOptions.StartupMode#LATEST startup mode of a streaming read.
DeltaFollowUpScanner	FollowUpScanner for CoreOptions.ChangelogProducer#NONE changelog producer.
FileCreationTimeStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_FILE_CREATION_TIME startup mode.
FullCompactedStartingScanner	StartingScanner for the CoreOptions.StartupMode.COMPACTED_FULL startup mode with 'full-compaction.delta-commits'.
FullStartingScanner	StartingScanner for the CoreOptions.StartupMode#LATEST_FULL startup mode.
IncrementalStartingScanner	StartingScanner for incremental changes by snapshot.
IncrementalTagStartingScanner	StartingScanner for incremental changes by tag.
IncrementalTimeStampStartingScanner	StartingScanner for incremental changes by timestamp.
InputChangelogFollowUpScanner	FollowUpScanner for CoreOptions.ChangelogProducer#INPUT changelog producer.
ReadPlanStartingScanner	An AbstractStartingScanner to return plan.
SnapshotReaderImpl	Implementation of SnapshotReader.
StartingContext	That contains some information that will be used out of StartingScanner.
StartingScanner.NextSnapshot	Return the next snapshot for followup scanning.
StartingScanner.NoSnapshot	Currently, there is no snapshot, need to wait for the snapshot to be generated.
StartingScanner.ScannedResult	Result with scanned snapshot.
StaticFromSnapshotStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT or CoreOptions.StartupMode#FROM_SNAPSHOT_FULL startup mode of a batch read.
StaticFromTagStartingScanner	StartingScanner for the CoreOptions.SCAN_TAG_NAME of a batch read.
StaticFromTimestampStartingScanner	StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode of a batch read.
StaticFromWatermarkStartingScanner	StartingScanner for the CoreOptions.SCAN_WATERMARK of a batch read.
TimeTravelUtil	The util class of resolve snapshot from scan params for time travel.