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.
ChangelogFollowUpScanner	FollowUpScanner for tables with changelog producer.
CompactedStartingScanner	StartingScanner for the CoreOptions.StartupMode#COMPACTED_FULL startup mode.
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.
EmptyResultStartingScanner	This scanner always return an empty result.
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.
IncrementalDeltaStartingScanner	Get incremental data by reading delta or changelog files from snapshots between start and end.
IncrementalDiffStartingScanner	Get incremental data by SnapshotReader.readIncrementalDiff(org.apache.paimon.Snapshot).
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.

Exception Summary

Exception	Description
TimeTravelUtil.InconsistentTagBucketException	Exception thrown when the bucket number of two tags are different in incremental tag query.