org.apache.reef.runtime.common.driver.context

Class ContextRepresenters

java.lang.Object

org.apache.reef.runtime.common.driver.context.ContextRepresenters

@ThreadSafe
public final class ContextRepresenters
extends Object

Driver-Side representation of all contexts on an Evaluator.

Method Summary

Methods

Modifier and Type	Method and Description
EvaluatorContext	getContext(String contextId) Fetch the context with the given ID.
List<FailedContext>	getFailedContextsForEvaluatorFailure() Create the failed contexts for a FailedEvaluator event.
void	onContextStatusMessages(Iterable<ReefServiceProtos.ContextStatusProto> contextStatusProtos, boolean notifyClientOnNewActiveContext) Process heartbeats from the contexts on an Evaluator.

Methods inherited from class java.lang.Object

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

Method Detail

getContext

public EvaluatorContext getContext(String contextId)

Fetch the context with the given ID.

Parameters:

contextId -

Returns:

getFailedContextsForEvaluatorFailure

public List<FailedContext> getFailedContextsForEvaluatorFailure()

Create the failed contexts for a FailedEvaluator event.

Returns:

onContextStatusMessages

public void onContextStatusMessages(Iterable<ReefServiceProtos.ContextStatusProto> contextStatusProtos,
                           boolean notifyClientOnNewActiveContext)

Process heartbeats from the contexts on an Evaluator.

Parameters:

contextStatusProto -

notifyClientOnNewActiveContext -