public final class TaskRepresenter extends Object
Constructor and Description |
---|
TaskRepresenter(String taskId,
EvaluatorContext context,
EvaluatorMessageDispatcher messageDispatcher,
EvaluatorManager evaluatorManager,
ExceptionCodec exceptionCodec,
DriverRestartManager driverRestartManager) |
Modifier and Type | Method and Description |
---|---|
boolean |
evaluatorIsClosed()
Check whether this evaluator is in closed state.
|
boolean |
evaluatorIsClosing()
Check whether this evaluator is in closing state.
|
String |
getId() |
boolean |
isClosable() |
boolean |
isNotRunning() |
void |
onTaskStatusMessage(TaskStatusPOJO taskStatus) |
public TaskRepresenter(String taskId, EvaluatorContext context, EvaluatorMessageDispatcher messageDispatcher, EvaluatorManager evaluatorManager, ExceptionCodec exceptionCodec, DriverRestartManager driverRestartManager)
public void onTaskStatusMessage(TaskStatusPOJO taskStatus)
public boolean isNotRunning()
public boolean isClosable()
public boolean evaluatorIsClosing()
public boolean evaluatorIsClosed()
Copyright © 2017 The Apache Software Foundation. All rights reserved.