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 |
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.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.