Uses of Class
org.apache.flink.connector.file.src.PendingSplitsCheckpoint

Packages that use PendingSplitsCheckpoint

Package	Description
org.apache.flink.connector.file.src
org.apache.flink.connector.file.src.impl

Uses of PendingSplitsCheckpoint in org.apache.flink.connector.file.src

Methods in org.apache.flink.connector.file.src that return PendingSplitsCheckpoint

Modifier and Type	Method	Description
PendingSplitsCheckpoint<T>	PendingSplitsCheckpointSerializer.deserialize(int version, byte[] serialized)
static <T extends FileSourceSplit> PendingSplitsCheckpoint<T>	PendingSplitsCheckpoint.fromCollectionSnapshot(Collection<T> splits)
static <T extends FileSourceSplit> PendingSplitsCheckpoint<T>	PendingSplitsCheckpoint.fromCollectionSnapshot(Collection<T> splits, Collection<org.apache.flink.core.fs.Path> alreadyProcessedPaths)

Methods in org.apache.flink.connector.file.src that return types with arguments of type PendingSplitsCheckpoint

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitT> enumContext)
org.apache.flink.core.io.SimpleVersionedSerializer<PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.getEnumeratorCheckpointSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitT> enumContext, PendingSplitsCheckpoint<SplitT> checkpoint)

Methods in org.apache.flink.connector.file.src with parameters of type PendingSplitsCheckpoint

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitT> enumContext, PendingSplitsCheckpoint<SplitT> checkpoint)
byte[]	PendingSplitsCheckpointSerializer.serialize(PendingSplitsCheckpoint<T> checkpoint)

Uses of PendingSplitsCheckpoint in org.apache.flink.connector.file.src.impl

Methods in org.apache.flink.connector.file.src.impl that return PendingSplitsCheckpoint

Modifier and Type	Method	Description
PendingSplitsCheckpoint<FileSourceSplit>	ContinuousFileSplitEnumerator.snapshotState(long checkpointId)
PendingSplitsCheckpoint<SplitT>	DynamicFileSplitEnumerator.snapshotState(long checkpointId)
PendingSplitsCheckpoint<FileSourceSplit>	StaticFileSplitEnumerator.snapshotState(long checkpointId)