org.apache.paimon.table.source.snapshot

Class CompactedStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.ReadPlanStartingScanner

org.apache.paimon.table.source.snapshot.CompactedStartingScanner

All Implemented Interfaces:

StartingScanner

public class CompactedStartingScanner
extends ReadPlanStartingScanner

StartingScanner for the CoreOptions.StartupMode#COMPACTED_FULL startup mode.

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
CompactedStartingScanner(SnapshotManager snapshotManager)

Method Summary

Modifier and Type	Method and Description
SnapshotReader	configure(SnapshotReader snapshotReader)
protected Long	pick()
ScanMode	startingScanMode()

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

scan, scanPartitions

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

startingContext

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

CompactedStartingScanner

public CompactedStartingScanner(SnapshotManager snapshotManager)

Method Detail

startingScanMode

public ScanMode startingScanMode()

Overrides:

startingScanMode in class AbstractStartingScanner

configure

public SnapshotReader configure(SnapshotReader snapshotReader)

Specified by:

configure in class ReadPlanStartingScanner

pick

@Nullable
protected Long pick()