public class IncrementalDeltaStartingScanner extends AbstractStartingScanner
StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
IncrementalDeltaStartingScanner(SnapshotManager snapshotManager,
long start,
long end,
ScanMode scanMode) |
Modifier and Type | Method and Description |
---|---|
static StartingScanner |
betweenSnapshotIds(long startId,
long endId,
SnapshotManager snapshotManager,
ScanMode scanMode) |
static IncrementalDeltaStartingScanner |
betweenTimestamps(long startTimestamp,
long endTimestamp,
SnapshotManager snapshotManager,
ScanMode scanMode) |
StartingScanner.Result |
scan(SnapshotReader reader) |
scanPartitions, startingContext, startingScanMode
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromPlan
public IncrementalDeltaStartingScanner(SnapshotManager snapshotManager, long start, long end, ScanMode scanMode)
public StartingScanner.Result scan(SnapshotReader reader)
public static StartingScanner betweenSnapshotIds(long startId, long endId, SnapshotManager snapshotManager, ScanMode scanMode)
public static IncrementalDeltaStartingScanner betweenTimestamps(long startTimestamp, long endTimestamp, SnapshotManager snapshotManager, ScanMode scanMode)
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.