public class ContinuousFromTimestampStartingScanner extends AbstractStartingScanner
StartingScanner
for the CoreOptions.StartupMode#FROM_TIMESTAMP
startup mode of a
streaming read.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager,
long startupMillis,
boolean changelogDecoupled) |
Modifier and Type | Method and Description |
---|---|
StartingScanner.Result |
scan(SnapshotReader snapshotReader) |
StartingContext |
startingContext() |
scanPartitions, startingScanMode
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromPlan
public ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager, long startupMillis, boolean changelogDecoupled)
public StartingContext startingContext()
startingContext
in interface StartingScanner
startingContext
in class AbstractStartingScanner
public StartingScanner.Result scan(SnapshotReader snapshotReader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.