Package | Description |
---|---|
org.apache.reef.runtime.common.driver.evaluator |
Driver-Side representations of Evaluators.
|
org.apache.reef.runtime.common.utils |
Runtime utilities used by various REEF modules.
|
org.apache.reef.runtime.mesos.util |
Utility for Mesos runtime.
|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
Modifier and Type | Method and Description |
---|---|
void |
EvaluatorManager.onEvaluatorHeartbeatMessage(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatProtoRemoteMessage)
Process an evaluator heartbeat message.
|
void |
EvaluatorHeartbeatHandler.onNext(RemoteMessage<EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto> evaluatorHeartbeatMessage) |
void |
EvaluatorResourceManagerErrorHandler.onNext(RemoteMessage<ReefServiceProtos.RuntimeErrorProto> runtimeErrorProtoRemoteMessage) |
Modifier and Type | Method and Description |
---|---|
<T,U extends T> |
RemoteManager.registerHandler(Class<U> messageType,
EventHandler<RemoteMessage<T>> theHandler) |
Modifier and Type | Method and Description |
---|---|
<T,U extends T> |
MesosRemoteManager.registerHandler(Class<U> messageType,
EventHandler<RemoteMessage<T>> theHandler) |
Modifier and Type | Method and Description |
---|---|
<T,U extends T> |
RemoteManager.registerHandler(Class<U> messageType,
EventHandler<RemoteMessage<T>> theHandler)
Registers the given EventHandler to be called for the given message type
from any source.
|
Modifier and Type | Method and Description |
---|---|
<T,U extends T> |
DefaultRemoteManagerImplementation.registerHandler(Class<U> messageType,
EventHandler<RemoteMessage<T>> theHandler)
Registers an event handler for a message type and returns a subscription.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.