Uses of Interface
org.apache.nemo.runtime.common.message.MessageSender

Packages that use MessageSender

Package	Description
org.apache.nemo.runtime.common.message
org.apache.nemo.runtime.common.message.grpc
org.apache.nemo.runtime.common.message.local
org.apache.nemo.runtime.common.message.ncs
org.apache.nemo.runtime.master.resource

Uses of MessageSender in org.apache.nemo.runtime.common.message

Classes in org.apache.nemo.runtime.common.message that implement MessageSender

Modifier and Type	Class	Description
class	FailedMessageSender	A message sender that failed.

Methods in org.apache.nemo.runtime.common.message that return MessageSender

Modifier and Type	Method	Description
MessageSender<ControlMessage.Message>	PersistentConnectionToMasterMap.getMessageSender(java.lang.String listenerId)	Get the message sender corresponding to the given listener ID.

Methods in org.apache.nemo.runtime.common.message that return types with arguments of type MessageSender

Modifier and Type	Method	Description
<T> java.util.concurrent.Future<MessageSender<T>>	MessageEnvironment.asyncConnect(java.lang.String receiverId, java.lang.String listenerId)	Asynchronously connect to the node called receiverId and return a future of MessageSender that sends messages to the listener with listenerId.

Uses of MessageSender in org.apache.nemo.runtime.common.message.grpc

Methods in org.apache.nemo.runtime.common.message.grpc that return types with arguments of type MessageSender

Modifier and Type	Method	Description
<T> java.util.concurrent.Future<MessageSender<T>>	GrpcMessageEnvironment.asyncConnect(java.lang.String receiverId, java.lang.String listenerId)

Uses of MessageSender in org.apache.nemo.runtime.common.message.local

Classes in org.apache.nemo.runtime.common.message.local that implement MessageSender

Modifier and Type	Class	Description
class	LocalMessageSender<T>	A simple MessageSender implementation that works on a single node.

Methods in org.apache.nemo.runtime.common.message.local that return types with arguments of type MessageSender

Modifier and Type	Method	Description
<T> java.util.concurrent.Future<MessageSender<T>>	LocalMessageEnvironment.asyncConnect(java.lang.String targetId, java.lang.String messageTypeId)

Uses of MessageSender in org.apache.nemo.runtime.common.message.ncs

Methods in org.apache.nemo.runtime.common.message.ncs that return types with arguments of type MessageSender

Modifier and Type	Method	Description
<T> java.util.concurrent.Future<MessageSender<T>>	NcsMessageEnvironment.asyncConnect(java.lang.String receiverId, java.lang.String listenerId)

Uses of MessageSender in org.apache.nemo.runtime.master.resource

Constructors in org.apache.nemo.runtime.master.resource with parameters of type MessageSender

Constructor	Description
DefaultExecutorRepresenter(java.lang.String executorId, ResourceSpecification resourceSpecification, MessageSender<ControlMessage.Message> messageSender, org.apache.reef.driver.context.ActiveContext activeContext, java.util.concurrent.ExecutorService serializationExecutorService, java.lang.String nodeName)	Creates a reference to the specified executor.