public class ContinuousLatestStartingScanner extends AbstractStartingScanner
StartingScanner
for the CoreOptions.StartupMode#LATEST
startup mode of a
streaming read.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
ContinuousLatestStartingScanner(SnapshotManager snapshotManager) |
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 ContinuousLatestStartingScanner(SnapshotManager snapshotManager)
public StartingScanner.Result scan(SnapshotReader snapshotReader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.