Uses of Package
org.apache.nemo.runtime.common.message
-
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.common.message Class Description ClientRPC Driver-side RPC implementation for communication from/to Nemo Client.MessageContext This class sends a reply message fromMessageListener.MessageListener Handles messages fromMessageSender.MessageSender This class sends messages toMessageListenerwith some defined semantics. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.common.message.grpc Class Description MessageEnvironment Set upMessageListeners to handle incoming messages on this node, and connect to remote nodes and returnMessageSenders to send message to them.MessageListener Handles messages fromMessageSender.MessageSender This class sends messages toMessageListenerwith some defined semantics. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.common.message.local Class Description MessageEnvironment Set upMessageListeners to handle incoming messages on this node, and connect to remote nodes and returnMessageSenders to send message to them.MessageListener Handles messages fromMessageSender.MessageSender This class sends messages toMessageListenerwith some defined semantics. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.common.message.ncs Class Description MessageEnvironment Set upMessageListeners to handle incoming messages on this node, and connect to remote nodes and returnMessageSenders to send message to them.MessageListener Handles messages fromMessageSender.MessageSender This class sends messages toMessageListenerwith some defined semantics. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.executor Class Description PersistentConnectionToMasterMap Persistent connection for sending messages to master. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.executor.datatransfer Class Description PersistentConnectionToMasterMap Persistent connection for sending messages to master. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.executor.task Class Description PersistentConnectionToMasterMap Persistent connection for sending messages to master. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.master Class Description MessageContext This class sends a reply message fromMessageListener.MessageListener Handles messages fromMessageSender. -
Classes in org.apache.nemo.runtime.common.message used by org.apache.nemo.runtime.master.resource Class Description MessageSender This class sends messages toMessageListenerwith some defined semantics.