org.apache.reef.runtime.common.driver.evaluator

Class EvaluatorMessageDispatcher

java.lang.Object

org.apache.reef.runtime.common.driver.evaluator.EvaluatorMessageDispatcher

All Implemented Interfaces:

AutoCloseable

public final class EvaluatorMessageDispatcher
extends Object
implements AutoCloseable

Central dispatcher for all Evaluator related events. This exists once per Evaluator.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	onContextActive(ActiveContext activeContext)
void	onContextClose(ClosedContext closedContext)
void	onContextFailed(FailedContext failedContext)
void	onContextMessage(ContextMessage contextMessage)
void	onDriverRestartContextActive(ActiveContext activeContext)
void	onDriverRestartEvaluatorFailed(FailedEvaluator failedEvaluator)
void	onDriverRestartTaskRunning(RunningTask runningTask)
void	onEvaluatorAllocated(AllocatedEvaluator allocatedEvaluator)
void	onEvaluatorCompleted(CompletedEvaluator completedEvaluator)
void	onEvaluatorFailed(FailedEvaluator failedEvaluator)
void	onTaskCompleted(CompletedTask completedTask)
void	onTaskFailed(FailedTask failedTask)
void	onTaskMessage(TaskMessage taskMessage)
void	onTaskRunning(RunningTask runningTask)
void	onTaskSuspended(SuspendedTask suspendedTask)

Methods inherited from class java.lang.Object

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

Method Detail

onEvaluatorAllocated

public void onEvaluatorAllocated(AllocatedEvaluator allocatedEvaluator)

onEvaluatorFailed

public void onEvaluatorFailed(FailedEvaluator failedEvaluator)

onEvaluatorCompleted

public void onEvaluatorCompleted(CompletedEvaluator completedEvaluator)

onTaskRunning

public void onTaskRunning(RunningTask runningTask)

onTaskCompleted

public void onTaskCompleted(CompletedTask completedTask)

onTaskSuspended

public void onTaskSuspended(SuspendedTask suspendedTask)

onTaskMessage

public void onTaskMessage(TaskMessage taskMessage)

onTaskFailed

public void onTaskFailed(FailedTask failedTask)

onContextActive

public void onContextActive(ActiveContext activeContext)

onContextClose

public void onContextClose(ClosedContext closedContext)

onContextFailed

public void onContextFailed(FailedContext failedContext)

onContextMessage

public void onContextMessage(ContextMessage contextMessage)

onDriverRestartTaskRunning

public void onDriverRestartTaskRunning(RunningTask runningTask)

onDriverRestartContextActive

public void onDriverRestartContextActive(ActiveContext activeContext)

onDriverRestartEvaluatorFailed

public void onDriverRestartEvaluatorFailed(FailedEvaluator failedEvaluator)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception