org.apache.paimon.table.source.snapshot

Class InputChangelogFollowUpScanner

java.lang.Object

org.apache.paimon.table.source.snapshot.InputChangelogFollowUpScanner

All Implemented Interfaces:

FollowUpScanner

public class InputChangelogFollowUpScanner
extends Object
implements FollowUpScanner

FollowUpScanner for CoreOptions.ChangelogProducer#INPUT changelog producer.

Constructor Summary

Constructors

Constructor and Description
InputChangelogFollowUpScanner()

Method Summary

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

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.FollowUpScanner

getOverwriteChangesPlan

Constructor Detail

InputChangelogFollowUpScanner

public InputChangelogFollowUpScanner()

Method Detail

shouldScanSnapshot

public boolean shouldScanSnapshot(Snapshot snapshot)

Specified by:

shouldScanSnapshot in interface FollowUpScanner

scan

public SnapshotReader.Plan scan(Snapshot snapshot,
                                SnapshotReader snapshotReader)

Specified by:

scan in interface FollowUpScanner