org.apache.paimon.table.source.snapshot

Class IncrementalTagStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.IncrementalTagStartingScanner

All Implemented Interfaces:

StartingScanner

public class IncrementalTagStartingScanner
extends AbstractStartingScanner

StartingScanner for incremental changes by tag.

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
IncrementalTagStartingScanner(SnapshotManager snapshotManager, String start, String end)

Method Summary

Modifier and Type	Method and Description
StartingScanner.Result	scan(SnapshotReader reader)

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

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

IncrementalTagStartingScanner

public IncrementalTagStartingScanner(SnapshotManager snapshotManager,
                                     String start,
                                     String end)

Method Detail

scan

public StartingScanner.Result scan(SnapshotReader reader)