org.apache.paimon.table.source.snapshot

Interface FollowUpScanner

All Known Implementing Classes:

AllDeltaFollowUpScanner, CompactionChangelogFollowUpScanner, CompactionDiffFollowUpScanner, DeltaFollowUpScanner, InputChangelogFollowUpScanner

public interface FollowUpScanner

Helper class for the follow-up planning of StreamTableScan.

Method Summary

Modifier and Type	Method and Description
default SnapshotReader.Plan	getOverwriteChangesPlan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	scan(Snapshot snapshot, SnapshotReader snapshotReader)
boolean	shouldScanSnapshot(Snapshot snapshot)

Method Detail

shouldScanSnapshot

boolean shouldScanSnapshot(Snapshot snapshot)

scan

SnapshotReader.Plan scan(Snapshot snapshot,
                         SnapshotReader snapshotReader)

getOverwriteChangesPlan

default SnapshotReader.Plan getOverwriteChangesPlan(Snapshot snapshot,
                                                    SnapshotReader snapshotReader)