org.apache.paimon.table.source.snapshot

Class IncrementalDeltaStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.IncrementalDeltaStartingScanner

All Implemented Interfaces:

StartingScanner

public class IncrementalDeltaStartingScanner
extends AbstractStartingScanner

Get incremental data by reading delta or changelog files from snapshots between start and end.

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
IncrementalDeltaStartingScanner(SnapshotManager snapshotManager, long start, long end, ScanMode scanMode)

Method Summary

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)

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

IncrementalDeltaStartingScanner

public IncrementalDeltaStartingScanner(SnapshotManager snapshotManager,
                                       long start,
                                       long end,
                                       ScanMode scanMode)

Method Detail

scan

public StartingScanner.Result scan(SnapshotReader reader)

betweenSnapshotIds

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

betweenTimestamps

public static IncrementalDeltaStartingScanner betweenTimestamps(long startTimestamp,
                                                                long endTimestamp,
                                                                SnapshotManager snapshotManager,
                                                                ScanMode scanMode)