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
org.apache.flink.connectors.hive

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 and 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<Path> alreadyProcessedPaths)

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

Modifier and Type	Method and Description
SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.createEnumerator(SplitEnumeratorContext<SplitT> enumContext)
SimpleVersionedSerializer<PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.getEnumeratorCheckpointSerializer()
SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.restoreEnumerator(SplitEnumeratorContext<SplitT> enumContext, PendingSplitsCheckpoint<SplitT> checkpoint)

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

Modifier and Type	Method and Description
SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.restoreEnumerator(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 and Description
PendingSplitsCheckpoint<FileSourceSplit>	StaticFileSplitEnumerator.snapshotState(long checkpointId)
PendingSplitsCheckpoint<SplitT>	DynamicFileSplitEnumerator.snapshotState(long checkpointId)
PendingSplitsCheckpoint<FileSourceSplit>	ContinuousFileSplitEnumerator.snapshotState(long checkpointId)

Uses of PendingSplitsCheckpoint in org.apache.flink.connectors.hive

Subclasses of PendingSplitsCheckpoint in org.apache.flink.connectors.hive

Modifier and Type	Class and Description
class	ContinuousHivePendingSplitsCheckpoint The checkpoint of current state of continuous hive source reading.

Methods in org.apache.flink.connectors.hive that return PendingSplitsCheckpoint

Modifier and Type	Method and Description
PendingSplitsCheckpoint<HiveSourceSplit>	ContinuousHivePendingSplitsCheckpointSerializer.deserialize(int version, byte[] serialized)
PendingSplitsCheckpoint<HiveSourceSplit>	ContinuousHiveSplitEnumerator.snapshotState(long checkpointId)

Methods in org.apache.flink.connectors.hive that return types with arguments of type PendingSplitsCheckpoint

Modifier and Type	Method and Description
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>>	HiveSource.createEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext)
SimpleVersionedSerializer<PendingSplitsCheckpoint<HiveSourceSplit>>	HiveSource.getEnumeratorCheckpointSerializer()
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>>	HiveSource.restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext, PendingSplitsCheckpoint<HiveSourceSplit> checkpoint)

Methods in org.apache.flink.connectors.hive with parameters of type PendingSplitsCheckpoint

Modifier and Type	Method and Description
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>>	HiveSource.restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext, PendingSplitsCheckpoint<HiveSourceSplit> checkpoint)
byte[]	ContinuousHivePendingSplitsCheckpointSerializer.serialize(PendingSplitsCheckpoint<HiveSourceSplit> checkpoint)