public final class EvaluatorMessageDispatcher extends Object
Modifier and Type | Method and Description |
---|---|
void |
onContextActive(ActiveContext activeContext) |
void |
onContextClose(ClosedContext closedContext) |
void |
onContextFailed(FailedContext failedContext) |
void |
onContextMessage(ContextMessage contextMessage) |
void |
OnDriverRestartCompleted(DriverRestartCompleted restartCompleted) |
void |
OnDriverRestartContextActive(ActiveContext activeContext) |
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) |
public void onEvaluatorAllocated(AllocatedEvaluator allocatedEvaluator)
public void onEvaluatorFailed(FailedEvaluator failedEvaluator)
public void onEvaluatorCompleted(CompletedEvaluator completedEvaluator)
public void onTaskRunning(RunningTask runningTask)
public void onTaskCompleted(CompletedTask completedTask)
public void onTaskSuspended(SuspendedTask suspendedTask)
public void onTaskMessage(TaskMessage taskMessage)
public void onTaskFailed(FailedTask failedTask)
public void onContextActive(ActiveContext activeContext)
public void onContextClose(ClosedContext closedContext)
public void onContextFailed(FailedContext failedContext)
public void onContextMessage(ContextMessage contextMessage)
public void onDriverRestartTaskRunning(RunningTask runningTask)
public void OnDriverRestartContextActive(ActiveContext activeContext)
public void OnDriverRestartCompleted(DriverRestartCompleted restartCompleted)
Copyright © 2015 The Apache Software Foundation. All rights reserved.