Package org.apache.flink.runtime.checkpoint

Class JobManagerTaskRestore

java.lang.Object

org.apache.flink.runtime.checkpoint.JobManagerTaskRestore

All Implemented Interfaces:

Serializable

public class JobManagerTaskRestore
extends Object
implements Serializable

This class encapsulates the data from the job manager to restore a task.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
JobManagerTaskRestore(long restoreCheckpointId, TaskStateSnapshot taskStateSnapshot)

Method Summary

Modifier and Type	Method	Description
long	getRestoreCheckpointId()
TaskStateSnapshot	getTaskStateSnapshot()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JobManagerTaskRestore

public JobManagerTaskRestore(@Nonnegative
                             long restoreCheckpointId,
                             @Nonnull
                             TaskStateSnapshot taskStateSnapshot)

Method Detail

getRestoreCheckpointId

public long getRestoreCheckpointId()

getTaskStateSnapshot

@Nonnull
public TaskStateSnapshot getTaskStateSnapshot()

toString

public String toString()

Overrides:

toString in class Object