public class IncrementalTimeStampStartingScanner extends AbstractStartingScanner
StartingScanner
for incremental changes by timestamp.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
IncrementalTimeStampStartingScanner(SnapshotManager snapshotManager,
long startTimestamp,
long endTimestamp,
ScanMode scanMode) |
Modifier and Type | Method and Description |
---|---|
StartingScanner.Result |
scan(SnapshotReader reader) |
scanPartitions, startingContext, startingScanMode
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromPlan
public IncrementalTimeStampStartingScanner(SnapshotManager snapshotManager, long startTimestamp, long endTimestamp, ScanMode scanMode)
public StartingScanner.Result scan(SnapshotReader reader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.