| Modifier and Type | Method and Description |
|---|---|
MessageSender<edu.snu.coral.runtime.common.comm.ControlMessage.Message> |
PersistentConnectionToMasterMap.getMessageSender(String listenerId)
Get the message sender corresponding to the given listener ID.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Future<MessageSender<T>> |
MessageEnvironment.asyncConnect(String receiverId,
String listenerId)
Asynchronously connect to the node called
receiverId and return a future of MessageSender
that sends messages to the listener with listenerId. |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<MessageSender<T>> |
GrpcMessageEnvironment.asyncConnect(String receiverId,
String listenerId) |
| Modifier and Type | Class and Description |
|---|---|
class |
LocalMessageSender<T>
A simple
MessageSender implementation that works on a single node. |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<MessageSender<T>> |
LocalMessageEnvironment.asyncConnect(String targetId,
String messageTypeId) |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<MessageSender<T>> |
NcsMessageEnvironment.asyncConnect(String receiverId,
String listenerId) |
| Constructor and Description |
|---|
ExecutorRepresenter(String executorId,
ResourceSpecification resourceSpecification,
MessageSender<edu.snu.coral.runtime.common.comm.ControlMessage.Message> messageSender,
org.apache.reef.driver.context.ActiveContext activeContext,
ExecutorService serializationExecutorService) |
Copyright © 2018. All rights reserved.