public final class EvaluatorRestartInfo extends Object
EvaluatorManager
for a recovered evaluator
on restart.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.
|
public static EvaluatorRestartInfo createExpectedEvaluatorInfo(ResourceRecoverEvent resourceRecoverEvent)
EvaluatorRestartInfo
object that represents the information of an evaluator that is expected
to recover.public static EvaluatorRestartInfo createFailedEvaluatorInfo(String evaluatorId)
EvaluatorRestartInfo
object that represents the information of an evaluator that
has failed on driver restart.public ResourceRecoverEvent getResourceRecoverEvent()
ResourceRecoverEvent
that contains the information (e.g. resource MB, node ID, Evaluator ID...)
needed to reconstruct the EvaluatorManager
of the
recovered evaluator on restart.public EvaluatorRestartState getEvaluatorRestartState()
public boolean setEvaluatorRestartState(EvaluatorRestartState to)
Copyright © 2017 The Apache Software Foundation. All rights reserved.