Uses of Class
org.apache.paimon.flink.source.PendingSplitsCheckpoint

Packages that use PendingSplitsCheckpoint

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

Uses of PendingSplitsCheckpoint in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return PendingSplitsCheckpoint

Modifier and Type	Method and Description
PendingSplitsCheckpoint	PendingSplitsCheckpointSerializer.deserialize(int version, byte[] serialized)
PendingSplitsCheckpoint	StaticFileStoreSplitEnumerator.snapshotState(long checkpointId)
PendingSplitsCheckpoint	ContinuousFileSplitEnumerator.snapshotState(long checkpointId)

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

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)

Methods in org.apache.paimon.flink.source with parameters of type PendingSplitsCheckpoint

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
byte[]	PendingSplitsCheckpointSerializer.serialize(PendingSplitsCheckpoint pendingSplitsCheckpoint)

Uses of PendingSplitsCheckpoint in org.apache.paimon.flink.source.align

Methods in org.apache.paimon.flink.source.align that return PendingSplitsCheckpoint

Modifier and Type	Method and Description
PendingSplitsCheckpoint	AlignedContinuousFileSplitEnumerator.snapshotState(long checkpointId)

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

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	AlignedContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)