Uses of Class
org.apache.flink.runtime.state.SerializedCheckpointData

Packages that use SerializedCheckpointData

Package	Description
org.apache.flink.runtime.state
org.apache.flink.streaming.api.functions.source

Uses of SerializedCheckpointData in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return SerializedCheckpointData

Modifier and Type	Method and Description
static <T> SerializedCheckpointData[]	SerializedCheckpointData.fromDeque(ArrayDeque<Tuple2<Long,List<T>>> checkpoints, TypeSerializer<T> serializer) Converts a list of checkpoints with elements into an array of SerializedCheckpointData.
static <T> SerializedCheckpointData[]	SerializedCheckpointData.fromDeque(ArrayDeque<Tuple2<Long,List<T>>> checkpoints, TypeSerializer<T> serializer, DataOutputSerializer outputBuffer) Converts a list of checkpoints into an array of SerializedCheckpointData.

Methods in org.apache.flink.runtime.state with parameters of type SerializedCheckpointData

Modifier and Type	Method and Description
static <T> ArrayDeque<Tuple2<Long,List<T>>>	SerializedCheckpointData.toDeque(SerializedCheckpointData[] data, TypeSerializer<T> serializer) De-serializes an array of SerializedCheckpointData back into an ArrayDeque of element checkpoints.

Uses of SerializedCheckpointData in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source that return SerializedCheckpointData

Modifier and Type	Method and Description
SerializedCheckpointData[]	MultipleIdsMessageAcknowledgingSourceBase.snapshotState(long checkpointId, long checkpointTimestamp)
SerializedCheckpointData[]	MessageAcknowledgingSourceBase.snapshotState(long checkpointId, long checkpointTimestamp)

Methods in org.apache.flink.streaming.api.functions.source with parameters of type SerializedCheckpointData

Modifier and Type	Method and Description
void	MessageAcknowledgingSourceBase.restoreState(SerializedCheckpointData[] state)