Uses of Interface
org.apache.nemo.runtime.common.message.MessageListener
-
-
Uses of MessageListener in org.apache.nemo.runtime.common.message
Methods in org.apache.nemo.runtime.common.message with parameters of type MessageListener Modifier and Type Method Description <T> void
MessageEnvironment. setupListener(java.lang.String listenerId, MessageListener<T> listener)
Set up aMessageListener
with a listener id. -
Uses of MessageListener in org.apache.nemo.runtime.common.message.grpc
Methods in org.apache.nemo.runtime.common.message.grpc with parameters of type MessageListener Modifier and Type Method Description <T> void
GrpcMessageEnvironment. setupListener(java.lang.String listenerId, MessageListener<T> listener)
-
Uses of MessageListener in org.apache.nemo.runtime.common.message.local
Methods in org.apache.nemo.runtime.common.message.local with parameters of type MessageListener Modifier and Type Method Description <T> void
LocalMessageEnvironment. setupListener(java.lang.String listenerId, MessageListener<T> listener)
-
Uses of MessageListener in org.apache.nemo.runtime.common.message.ncs
Methods in org.apache.nemo.runtime.common.message.ncs with parameters of type MessageListener Modifier and Type Method Description <T> void
NcsMessageEnvironment. setupListener(java.lang.String listenerId, MessageListener<T> listener)
-
Uses of MessageListener in org.apache.nemo.runtime.master
Classes in org.apache.nemo.runtime.master that implement MessageListener Modifier and Type Class Description class
BlockManagerMaster.BlockManagerMasterControlMessageReceiver
Handler for control messages received.class
PipeManagerMaster.PipeManagerMasterControlMessageReceiver
Handler for control messages received.class
RuntimeMaster.MasterControlMessageReceiver
Handler for control messages received by Master.
-