class |
CompactedStartingScanner
StartingScanner for the CoreOptions.StartupMode#COMPACTED_FULL startup mode.
|
class |
ContinuousCompactorStartingScanner
StartingScanner used internally for stand-alone streaming compact job sources.
|
class |
ContinuousFromSnapshotFullStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT_FULL startup mode
of a batch read.
|
class |
ContinuousFromSnapshotStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT startup mode of a
streaming read.
|
class |
ContinuousFromTimestampStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode of a
streaming read.
|
class |
ContinuousLatestStartingScanner
StartingScanner for the CoreOptions.StartupMode#LATEST startup mode of a
streaming read.
|
class |
FileCreationTimeStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_FILE_CREATION_TIME startup
mode.
|
class |
FullCompactedStartingScanner
|
class |
FullStartingScanner
|
class |
IncrementalStartingScanner
|
class |
IncrementalTagStartingScanner
|
class |
IncrementalTimeStampStartingScanner
|
class |
StaticFromSnapshotStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_SNAPSHOT or CoreOptions.StartupMode#FROM_SNAPSHOT_FULL startup mode of a batch read.
|
class |
StaticFromTagStartingScanner
|
class |
StaticFromTimestampStartingScanner
StartingScanner for the CoreOptions.StartupMode#FROM_TIMESTAMP startup mode of a
batch read.
|
class |
StaticFromWatermarkStartingScanner
|