org.apache.reef.runtime.common.driver.evaluator

Class EvaluatorControlHandler

java.lang.Object

org.apache.reef.runtime.common.driver.evaluator.EvaluatorControlHandler

public final class EvaluatorControlHandler
extends Object

This class handles the sending of Evaluator control messages to the Evaluator.

Method Summary

Methods

Modifier and Type	Method and Description
void	send(EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControlProto) Send the evaluatorControlProto to the Evaluator.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

send

public void send(EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControlProto)

Send the evaluatorControlProto to the Evaluator.

Parameters:

evaluatorControlProto -

Throws:

IllegalStateException - if the remote ID hasn't been set via setRemoteID() prior to this call

IllegalStateException - if the Evaluator isn't running.