org.apache.reef.driver.restart

Class EvaluatorRestartInfo

java.lang.Object

org.apache.reef.driver.restart.EvaluatorRestartInfo

public final class EvaluatorRestartInfo
extends Object

An object that encapsulates the information needed to construct an EvaluatorManager for a recovered evaluator on restart.

Method Summary

Methods

Modifier and Type	Method and Description
static EvaluatorRestartInfo	createExpectedEvaluatorInfo(ResourceRecoverEvent resourceRecoverEvent) Creates an EvaluatorRestartInfo object that represents the information of an evaluator that is expected to recover.
static EvaluatorRestartInfo	createFailedEvaluatorInfo(String evaluatorId) Creates an EvaluatorRestartInfo object that represents the information of an evaluator that has failed on driver restart.
EvaluatorRestartState	getEvaluatorRestartState()
ResourceRecoverEvent	getResourceRecoverEvent()
boolean	setEvaluatorRestartState(EvaluatorRestartState to) sets the current process of the restart.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createExpectedEvaluatorInfo

public static EvaluatorRestartInfo createExpectedEvaluatorInfo(ResourceRecoverEvent resourceRecoverEvent)

Creates an EvaluatorRestartInfo object that represents the information of an evaluator that is expected to recover.

createFailedEvaluatorInfo

public static EvaluatorRestartInfo createFailedEvaluatorInfo(String evaluatorId)

Creates an EvaluatorRestartInfo object that represents the information of an evaluator that has failed on driver restart.

getResourceRecoverEvent

public ResourceRecoverEvent getResourceRecoverEvent()

Returns:

the ResourceRecoverEvent that contains the information (e.g. resource MB, node ID, Evaluator ID...) needed to reconstruct the EvaluatorManager of the recovered evaluator on restart.

getEvaluatorRestartState

public EvaluatorRestartState getEvaluatorRestartState()

Returns:

the current process of the restart.

setEvaluatorRestartState

public boolean setEvaluatorRestartState(EvaluatorRestartState to)

sets the current process of the restart.