public class ContinuousCompactorStartingScanner extends AbstractStartingScanner
StartingScanner
used internally for stand-alone streaming compact job sources.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
ContinuousCompactorStartingScanner(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 ContinuousCompactorStartingScanner(SnapshotManager snapshotManager)
public StartingScanner.Result scan(SnapshotReader snapshotReader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.