public class IncrementalDiffStartingScanner extends AbstractStartingScanner
SnapshotReader.readIncrementalDiff(org.apache.paimon.Snapshot)
.StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult
snapshotManager, startingSnapshotId
Constructor and Description |
---|
IncrementalDiffStartingScanner(SnapshotManager snapshotManager,
Snapshot start,
Snapshot end) |
Modifier and Type | Method and Description |
---|---|
static StartingScanner |
betweenSnapshotIds(long startId,
long endId,
SnapshotManager snapshotManager) |
static StartingScanner |
betweenTags(Tag startTag,
Tag endTag,
SnapshotManager snapshotManager,
Pair<String,String> incrementalBetween) |
static IncrementalDiffStartingScanner |
betweenTimestamps(long startTimestamp,
long endTimestamp,
SnapshotManager snapshotManager) |
StartingScanner.Result |
scan(SnapshotReader reader) |
static AbstractStartingScanner |
toEndAutoTag(SnapshotManager snapshotManager,
String endTagName,
CoreOptions options) |
scanPartitions, startingContext, startingScanMode
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromPlan
public IncrementalDiffStartingScanner(SnapshotManager snapshotManager, Snapshot start, Snapshot end)
public StartingScanner.Result scan(SnapshotReader reader)
public static StartingScanner betweenTags(Tag startTag, Tag endTag, SnapshotManager snapshotManager, Pair<String,String> incrementalBetween)
public static StartingScanner betweenSnapshotIds(long startId, long endId, SnapshotManager snapshotManager)
public static IncrementalDiffStartingScanner betweenTimestamps(long startTimestamp, long endTimestamp, SnapshotManager snapshotManager)
public static AbstractStartingScanner toEndAutoTag(SnapshotManager snapshotManager, String endTagName, CoreOptions options)
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.