Package org.apache.nemo.runtime.common.message
-
Interface Summary Interface Description MessageContext This class sends a reply message fromMessageListener
.MessageEnvironment Set upMessageListener
s to handle incoming messages on this node, and connect to remote nodes and returnMessageSender
s to send message to them.MessageListener<T> Handles messages fromMessageSender
.MessageSender<T> This class sends messages toMessageListener
with some defined semantics. -
Class Summary Class Description ClientRPC Driver-side RPC implementation for communication from/to Nemo Client.FailedMessageSender A message sender that failed.MessageParameters Parameters for message components.MessageParameters.SenderId Id of the sender.MessageUtils Utility class for messages.PersistentConnectionToMasterMap Persistent connection for sending messages to master.