Uses of Class
org.apache.flink.runtime.checkpoint.JobManagerTaskRestore

Packages that use JobManagerTaskRestore

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.state

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

Methods in org.apache.flink.runtime.deployment that return JobManagerTaskRestore

Modifier and Type	Method	Description
JobManagerTaskRestore	TaskDeploymentDescriptor.getTaskRestore()

Method parameters in org.apache.flink.runtime.deployment with type arguments of type JobManagerTaskRestore

Modifier and Type	Method	Description
TaskDeploymentDescriptor	TaskDeploymentDescriptorFactory.createDeploymentDescriptor(Execution execution, AllocationID allocationID, org.apache.flink.types.Either<org.apache.flink.util.SerializedValue<JobManagerTaskRestore>,PermanentBlobKey> taskRestore, Collection<ResultPartitionDeploymentDescriptor> producedPartitions)

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

Methods in org.apache.flink.runtime.executiongraph that return JobManagerTaskRestore

Modifier and Type	Method	Description
JobManagerTaskRestore	Execution.getTaskRestore()

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type JobManagerTaskRestore

Modifier and Type	Method	Description
protected org.apache.flink.types.Either<org.apache.flink.util.SerializedValue<JobManagerTaskRestore>,PermanentBlobKey>	Execution.getMaybeOffloadedTaskRestore(JobManagerTaskRestore taskRestoreSnapshot)	Returns the serialized task restore information or the blob key if it was offloaded.

Methods in org.apache.flink.runtime.executiongraph with parameters of type JobManagerTaskRestore

Modifier and Type	Method	Description
protected org.apache.flink.types.Either<org.apache.flink.util.SerializedValue<JobManagerTaskRestore>,PermanentBlobKey>	Execution.getMaybeOffloadedTaskRestore(JobManagerTaskRestore taskRestoreSnapshot)	Returns the serialized task restore information or the blob key if it was offloaded.
void	Execution.setInitialState(JobManagerTaskRestore taskRestore)	Sets the initial state for the execution.

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

Constructors in org.apache.flink.runtime.state with parameters of type JobManagerTaskRestore

Constructor	Description
TaskStateManagerImpl(org.apache.flink.api.common.JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, FileMergingSnapshotManagerClosableWrapper fileMergingSnapshotManager, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder)
TaskStateManagerImpl(org.apache.flink.api.common.JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, FileMergingSnapshotManagerClosableWrapper fileMergingSnapshotManager, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder, SequentialChannelStateReaderImpl sequentialChannelStateReader)