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.