public final class HeartBeatManager extends Object
Modifier and Type | Method and Description |
---|---|
void |
sendContextStatus(ReefServiceProtos.ContextStatusProto contextStatusProto)
Called with a specific ContextStatus that must be delivered to the driver.
|
void |
sendEvaluatorStatus(ReefServiceProtos.EvaluatorStatusProto evaluatorStatusProto)
Called with a specific EvaluatorStatus that must be delivered to the driver.
|
void |
sendHeartbeat()
Assemble a complete new heartbeat and send it out.
|
void |
sendTaskStatus(ReefServiceProtos.TaskStatusProto taskStatusProto)
Called with a specific TaskStatus that must be delivered to the driver.
|
public void sendHeartbeat()
public void sendTaskStatus(ReefServiceProtos.TaskStatusProto taskStatusProto)
public void sendContextStatus(ReefServiceProtos.ContextStatusProto contextStatusProto)
public void sendEvaluatorStatus(ReefServiceProtos.EvaluatorStatusProto evaluatorStatusProto)
Copyright © 2017 The Apache Software Foundation. All rights reserved.