org.apache.paimon.table.source.snapshot

Class IncrementalDiffStartingScanner

java.lang.Object

org.apache.paimon.table.source.snapshot.AbstractStartingScanner

org.apache.paimon.table.source.snapshot.IncrementalDiffStartingScanner

All Implemented Interfaces:

StartingScanner

public class IncrementalDiffStartingScanner
extends AbstractStartingScanner

Get incremental data by SnapshotReader.readIncrementalDiff(org.apache.paimon.Snapshot).

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.source.snapshot.StartingScanner

StartingScanner.NextSnapshot, StartingScanner.NoSnapshot, StartingScanner.Result, StartingScanner.ScannedResult

Field Summary

Fields inherited from class org.apache.paimon.table.source.snapshot.AbstractStartingScanner

snapshotManager, startingSnapshotId

Constructor Summary

Constructors

Constructor and Description
IncrementalDiffStartingScanner(SnapshotManager snapshotManager, Snapshot start, Snapshot end)

Method Summary

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)

Methods inherited from class org.apache.paimon.table.source.snapshot.AbstractStartingScanner

scanPartitions, startingContext, startingScanMode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.source.snapshot.StartingScanner

fromPlan

Constructor Detail

IncrementalDiffStartingScanner

public IncrementalDiffStartingScanner(SnapshotManager snapshotManager,
                                      Snapshot start,
                                      Snapshot end)

Method Detail

scan

public StartingScanner.Result scan(SnapshotReader reader)

betweenTags

public static StartingScanner betweenTags(Tag startTag,
                                          Tag endTag,
                                          SnapshotManager snapshotManager,
                                          Pair<String,String> incrementalBetween)

betweenSnapshotIds

public static StartingScanner betweenSnapshotIds(long startId,
                                                 long endId,
                                                 SnapshotManager snapshotManager)

betweenTimestamps

public static IncrementalDiffStartingScanner betweenTimestamps(long startTimestamp,
                                                               long endTimestamp,
                                                               SnapshotManager snapshotManager)

toEndAutoTag

public static AbstractStartingScanner toEndAutoTag(SnapshotManager snapshotManager,
                                                   String endTagName,
                                                   CoreOptions options)