public final class EvaluatorMessageDispatcher extends Object implements AutoCloseable
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) |
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 onDriverRestartEvaluatorFailed(FailedEvaluator failedEvaluator)
public void close()
close
in interface AutoCloseable
Copyright © 2017 The Apache Software Foundation. All rights reserved.