org.apache.paimon.table.source.snapshot

Class FullCompactedStartingScanner

java.lang.Object

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

org.apache.paimon.table.source.snapshot.FullCompactedStartingScanner

All Implemented Interfaces:

StartingScanner

public class FullCompactedStartingScanner
extends AbstractStartingScanner

StartingScanner for the CoreOptions.StartupMode.COMPACTED_FULL startup mode with 'full-compaction.delta-commits'.

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
FullCompactedStartingScanner(SnapshotManager snapshotManager, int deltaCommits)

Method Summary

Modifier and Type	Method and Description
static boolean	isFullCompactedIdentifier(long identifier, int deltaCommits)
protected Long	pick()
StartingScanner.Result	scan(SnapshotReader snapshotReader)
ScanMode	startingScanMode()

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

FullCompactedStartingScanner

public FullCompactedStartingScanner(SnapshotManager snapshotManager,
                                    int deltaCommits)

Method Detail

pick

@Nullable
protected Long pick()

startingScanMode

public ScanMode startingScanMode()

Overrides:

startingScanMode in class AbstractStartingScanner

scan

public StartingScanner.Result scan(SnapshotReader snapshotReader)

isFullCompactedIdentifier

public static boolean isFullCompactedIdentifier(long identifier,
                                                int deltaCommits)