public class FullCompactedStartingScanner extends ReadPlanStartingScanner
StartingScanner
for the CoreOptions.StartupMode.COMPACTED_FULL
startup mode with
'full-compaction.delta-commits'.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
FullCompactedStartingScanner(SnapshotManager snapshotManager,
int deltaCommits) |
Modifier and Type | Method and Description |
---|---|
SnapshotReader |
configure(SnapshotReader snapshotReader) |
static boolean |
isFullCompactedIdentifier(long identifier,
int deltaCommits) |
protected Long |
pick() |
ScanMode |
startingScanMode() |
scan, scanPartitions
startingContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromPlan
public FullCompactedStartingScanner(SnapshotManager snapshotManager, int deltaCommits)
public ScanMode startingScanMode()
startingScanMode
in class AbstractStartingScanner
public SnapshotReader configure(SnapshotReader snapshotReader)
configure
in class ReadPlanStartingScanner
public static boolean isFullCompactedIdentifier(long identifier, int deltaCommits)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.