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