Uses of Interface
org.apache.flink.runtime.state.StateHandle

Packages that use StateHandle

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobManager and TaskManager to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.state
org.apache.flink.runtime.taskmanager

Uses of StateHandle in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return types with arguments of type StateHandle

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	StateForTask.getState()

Method parameters in org.apache.flink.runtime.checkpoint with type arguments of type StateHandle

Modifier and Type	Method and Description
boolean	PendingCheckpoint.acknowledgeTask(ExecutionAttemptID attemptID, SerializedValue<StateHandle<?>> state)

Constructor parameters in org.apache.flink.runtime.checkpoint with type arguments of type StateHandle

Constructor and Description
StateForTask(SerializedValue<StateHandle<?>> state, JobVertexID operatorId, int subtask)

Uses of StateHandle in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return types with arguments of type StateHandle

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	TaskDeploymentDescriptor.getOperatorState()

Constructor parameters in org.apache.flink.runtime.deployment with type arguments of type StateHandle

Constructor and Description

TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, SerializedValue<StateHandle<?>> operatorState) Constructs a task deployment descriptor.

Uses of StateHandle in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution with parameters of type StateHandle

Modifier and Type	Method and Description
void	Environment.acknowledgeCheckpoint(long checkpointId, StateHandle<?> state) Confirms that the invokable has successfully completed all steps it needed to to for the checkpoint with the give checkpoint-ID.

Uses of StateHandle in org.apache.flink.runtime.executiongraph

Method parameters in org.apache.flink.runtime.executiongraph with type arguments of type StateHandle

Modifier and Type	Method and Description
void	Execution.setInitialState(SerializedValue<StateHandle<?>> initialState)

Uses of StateHandle in org.apache.flink.runtime.jobgraph.tasks

Classes in org.apache.flink.runtime.jobgraph.tasks with type parameters of type StateHandle

Modifier and Type	Interface and Description
interface	OperatorStateCarrier<T extends StateHandle<?>> This interface must be implemented by any invokable that has recoverable state.

Uses of StateHandle in org.apache.flink.runtime.messages.checkpoint

Methods in org.apache.flink.runtime.messages.checkpoint that return types with arguments of type StateHandle

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	AcknowledgeCheckpoint.getState()

Constructor parameters in org.apache.flink.runtime.messages.checkpoint with type arguments of type StateHandle

Constructor and Description
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, SerializedValue<StateHandle<?>> state)

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

Classes in org.apache.flink.runtime.state that implement StateHandle

Modifier and Type	Class and Description
class	ByteStreamStateHandle Statehandle that writes/reads the contents of the serializable checkpointed state to the provided input and outputstreams using default java serialization.
class	FileStateHandle Statehandle that writes the checkpointed state to a random file in the provided checkpoint directory.
class	LocalStateHandle A StateHandle that includes the operator states directly.

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

Modifier and Type	Method and Description
static <T extends StateHandle<?>> void	StateUtils.setOperatorState(OperatorStateCarrier<?> op, StateHandle<?> state) Utility method to define a common generic bound to be used for setting a generic state handle on a generic state carrier.

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

Modifier and Type	Method and Description
StateHandle<T>	StateHandleProvider.createStateHandle(T state) Creates a new StateHandle instance that will be used to store the state checkpoint.

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

Modifier and Type	Method and Description
static <T extends StateHandle<?>> void	StateUtils.setOperatorState(OperatorStateCarrier<?> op, StateHandle<?> state) Utility method to define a common generic bound to be used for setting a generic state handle on a generic state carrier.

Uses of StateHandle in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager with parameters of type StateHandle

Modifier and Type	Method and Description
void	RuntimeEnvironment.acknowledgeCheckpoint(long checkpointId, StateHandle<?> state)