public final class EvaluatorManager extends Object implements Identifiable, AutoCloseable
Modifier and Type | Class and Description |
---|---|
static class |
EvaluatorManager.EvaluatorDescriptorName |
static class |
EvaluatorManager.EvaluatorIdentifier |
Modifier and Type | Method and Description |
---|---|
void |
close() |
EvaluatorDescriptor |
getEvaluatorDescriptor() |
String |
getId()
Returns an identifier of this object
|
static String |
getJobIdentifier()
Get the id of current job/application
|
boolean |
isClosed()
Return true if the state is DONE, FAILED, or KILLED,
and there are no messages queued or in processing.
|
void |
onEvaluatorException(EvaluatorException exception)
EvaluatorException will trigger is FailedEvaluator and state transition to FAILED
|
void |
onEvaluatorHeartbeatMessage(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatProtoRemoteMessage) |
void |
onResourceLaunch(ResourceLaunchEvent resourceLaunchEvent) |
void |
onResourceStatusMessage(ResourceStatusEvent resourceStatusEvent)
Resource status information from the (actual) resource manager.
|
void |
sendContextControlMessage(EvaluatorRuntimeProtocol.ContextControlProto contextControlProto)
Packages the ContextControlProto in an EvaluatorControlProto and forward it to the EvaluatorRuntime
|
void |
setType(EvaluatorType type) |
String |
toString() |
public static String getJobIdentifier()
public String getId()
Identifiable
getId
in interface Identifiable
public void setType(EvaluatorType type)
public EvaluatorDescriptor getEvaluatorDescriptor()
public void close()
close
in interface AutoCloseable
public boolean isClosed()
public void onEvaluatorException(EvaluatorException exception)
exception
- on the EvaluatorRuntimepublic void onEvaluatorHeartbeatMessage(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatProtoRemoteMessage)
public void onResourceLaunch(ResourceLaunchEvent resourceLaunchEvent)
public void sendContextControlMessage(EvaluatorRuntimeProtocol.ContextControlProto contextControlProto)
contextControlProto
- message contains context control info.public void onResourceStatusMessage(ResourceStatusEvent resourceStatusEvent)
Copyright © 2015 The Apache Software Foundation. All rights reserved.