Uses of Class
org.apache.paimon.flink.source.ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Packages that use ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Package	Description
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align

Uses of ContinuousFileSplitEnumerator.PlanWithNextSnapshotId in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return types with arguments of type ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Modifier and Type	Method and Description
protected Optional<ContinuousFileSplitEnumerator.PlanWithNextSnapshotId>	ContinuousFileSplitEnumerator.scanNextSnapshot()

Method parameters in org.apache.paimon.flink.source with type arguments of type ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Modifier and Type	Method and Description
protected void	ContinuousFileSplitEnumerator.processDiscoveredSplits(Optional<ContinuousFileSplitEnumerator.PlanWithNextSnapshotId> planWithNextSnapshotIdOptional, Throwable error)

Uses of ContinuousFileSplitEnumerator.PlanWithNextSnapshotId in org.apache.paimon.flink.source.align

Methods in org.apache.paimon.flink.source.align that return types with arguments of type ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Modifier and Type	Method and Description
protected Optional<ContinuousFileSplitEnumerator.PlanWithNextSnapshotId>	AlignedContinuousFileSplitEnumerator.scanNextSnapshot()

Method parameters in org.apache.paimon.flink.source.align with type arguments of type ContinuousFileSplitEnumerator.PlanWithNextSnapshotId

Modifier and Type	Method and Description
protected void	AlignedContinuousFileSplitEnumerator.processDiscoveredSplits(Optional<ContinuousFileSplitEnumerator.PlanWithNextSnapshotId> ignore, Throwable error)