Uses of Class
org.apache.reef.io.network.group.impl.GroupCommunicationMessage

Packages that use GroupCommunicationMessage

Package	Description
org.apache.reef.io.network.group.api.driver	Elastic Group Communications Driver-side API Interfaces.
org.apache.reef.io.network.group.api.task	Elastic Group Communications Task-side API Interfaces.
org.apache.reef.io.network.group.impl	Implementations for Elastic Group Communications.
org.apache.reef.io.network.group.impl.driver	This package contains the implementation of the driver side of the Group Communication Service using the tree/flat topology.
org.apache.reef.io.network.group.impl.operators	Implementations for Group Communication Operators.
org.apache.reef.io.network.group.impl.task	Implementations for Elastic Group Communications Task-side API.
org.apache.reef.io.network.group.impl.utils	Utilities for group communication.

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.api.driver

Methods in org.apache.reef.io.network.group.api.driver with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	TaskNode.onReceiptOfAcknowledgement(GroupCommunicationMessage msg)
void	Topology.onReceiptOfMessage(GroupCommunicationMessage msg) Update state on receipt of a message.
void	TaskNodeStatus.processAcknowledgement(GroupCommunicationMessage msg) Process the msg that was received and update.

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.api.task

Methods in org.apache.reef.io.network.group.api.task that return GroupCommunicationMessage

Modifier and Type	Method and Description
GroupCommunicationMessage	CommGroupNetworkHandler.waitForTopologyUpdate(Class<? extends Name<String>> operName)

Methods in org.apache.reef.io.network.group.api.task with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	OperatorTopologyStruct.addAsData(GroupCommunicationMessage msg)
void	NodeStruct.addData(GroupCommunicationMessage msg)
void	OperatorTopology.handle(GroupCommunicationMessage msg)
void	OperatorTopologyStruct.update(GroupCommunicationMessage msg)

Method parameters in org.apache.reef.io.network.group.api.task with type arguments of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	GroupCommNetworkHandler.register(Class<? extends Name<String>> groupName, EventHandler<GroupCommunicationMessage> commGroupNetworkHandler)
void	CommGroupNetworkHandler.register(Class<? extends Name<String>> operName, EventHandler<GroupCommunicationMessage> handler)
void	OperatorTopologyStruct.update(Set<GroupCommunicationMessage> deletionDeltas)

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.impl

Methods in org.apache.reef.io.network.group.impl that return GroupCommunicationMessage

Modifier and Type	Method and Description
GroupCommunicationMessage	GroupCommunicationMessageCodec.decode(byte[] data)
GroupCommunicationMessage	GroupCommunicationMessageCodec.decodeFromStream(DataInputStream stream)

Methods in org.apache.reef.io.network.group.impl with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
byte[]	GroupCommunicationMessageCodec.encode(GroupCommunicationMessage msg)
void	GroupCommunicationMessageCodec.encodeToStream(GroupCommunicationMessage msg, DataOutputStream stream)

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.impl.driver

Methods in org.apache.reef.io.network.group.impl.driver that return GroupCommunicationMessage

Modifier and Type	Method and Description
GroupCommunicationMessage	IndexedMsg.getMsg()

Methods in org.apache.reef.io.network.group.impl.driver with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	TopologyMessageHandler.onNext(GroupCommunicationMessage msg)
void	GroupCommMessageHandler.onNext(GroupCommunicationMessage msg)
void	CtrlMsgSender.onNext(GroupCommunicationMessage srcCtrlMsg)
void	TaskNodeImpl.onReceiptOfAcknowledgement(GroupCommunicationMessage msg) * Methods pertaining to my neighbors status change ends ***.
void	TreeTopology.onReceiptOfMessage(GroupCommunicationMessage msg)
void	FlatTopology.onReceiptOfMessage(GroupCommunicationMessage msg)
void	TaskNodeStatusImpl.processAcknowledgement(GroupCommunicationMessage gcm)
void	CommunicationGroupDriverImpl.processMsg(GroupCommunicationMessage msg)
void	CommunicationGroupDriverImpl.queNProcessMsg(GroupCommunicationMessage msg)

Method parameters in org.apache.reef.io.network.group.impl.driver with type arguments of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	GroupCommMessageHandler.addHandler(Class<? extends Name<String>> groupName, SingleThreadStage<GroupCommunicationMessage> stage)

Constructors in org.apache.reef.io.network.group.impl.driver with parameters of type GroupCommunicationMessage

Constructor and Description
IndexedMsg(GroupCommunicationMessage msg)
MsgKey(GroupCommunicationMessage msg)

Constructor parameters in org.apache.reef.io.network.group.impl.driver with type arguments of type GroupCommunicationMessage

Constructor and Description
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.
CtrlMsgSender(IdentifierFactory idFac, NetworkService<GroupCommunicationMessage> netService)
TaskNodeImpl(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operatorName, String taskId, String driverId, boolean isRoot)
TopologyUpdateWaitHandler(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, String driverId, int driverVersion, String dstId, int dstVersion, String qualifiedName, byte[] data) The handler will wait for all nodes to acquire topoLock and send TopologySetup msg.

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.impl.operators

Methods in org.apache.reef.io.network.group.impl.operators with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	ScatterSender.onNext(GroupCommunicationMessage msg)
void	ScatterReceiver.onNext(GroupCommunicationMessage msg)
void	ReduceSender.onNext(GroupCommunicationMessage msg)
void	ReduceReceiver.onNext(GroupCommunicationMessage msg)
void	GatherSender.onNext(GroupCommunicationMessage msg)
void	GatherReceiver.onNext(GroupCommunicationMessage msg)
void	BroadcastSender.onNext(GroupCommunicationMessage msg)
void	BroadcastReceiver.onNext(GroupCommunicationMessage msg)
void	Sender.send(GroupCommunicationMessage msg)
void	Sender.send(GroupCommunicationMessage msg, String dest)

Constructor parameters in org.apache.reef.io.network.group.impl.operators with type arguments of type GroupCommunicationMessage

Constructor and Description
BroadcastReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
BroadcastSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceSender(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ScatterReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterDecoder scatterDecoder)
ScatterSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterEncoder scatterEncoder)
Sender(NetworkService<GroupCommunicationMessage> netService)

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.impl.task

Methods in org.apache.reef.io.network.group.impl.task that return GroupCommunicationMessage

Modifier and Type	Method and Description
GroupCommunicationMessage	CommGroupNetworkHandlerImpl.waitForTopologyUpdate(Class<? extends Name<String>> operName)

Methods in org.apache.reef.io.network.group.impl.task with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	OperatorTopologyStructImpl.addAsData(GroupCommunicationMessage msg)
void	NodeStructImpl.addData(GroupCommunicationMessage msg)
boolean	ParentNodeStruct.checkDead(GroupCommunicationMessage gcm)
abstract boolean	NodeStructImpl.checkDead(GroupCommunicationMessage gcm)
boolean	ChildNodeStruct.checkDead(GroupCommunicationMessage gcm)
void	OperatorTopologyImpl.handle(GroupCommunicationMessage msg) Handle messages meant for this operator.
void	CommGroupNetworkHandlerImpl.onNext(GroupCommunicationMessage msg)
void	OperatorTopologyStructImpl.update(GroupCommunicationMessage msg) Updates the topology structure with the received message.

Method parameters in org.apache.reef.io.network.group.impl.task with type arguments of type GroupCommunicationMessage

Modifier and Type	Method and Description
void	GroupCommNetworkHandlerImpl.onNext(Message<GroupCommunicationMessage> mesg)
void	GroupCommNetworkHandlerImpl.register(Class<? extends Name<String>> groupName, EventHandler<GroupCommunicationMessage> commGroupNetworkHandler)
void	CommGroupNetworkHandlerImpl.register(Class<? extends Name<String>> operName, EventHandler<GroupCommunicationMessage> operHandler)
void	OperatorTopologyStructImpl.update(Set<GroupCommunicationMessage> deletionDeltas)

Uses of GroupCommunicationMessage in org.apache.reef.io.network.group.impl.utils

Methods in org.apache.reef.io.network.group.impl.utils that return GroupCommunicationMessage

Modifier and Type	Method and Description
static GroupCommunicationMessage	Utils.bldVersionedGCM(Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String from, int srcVersion, String to, int dstVersion, byte[]... data)
static GroupCommunicationMessage	Utils.getGCM(Message<GroupCommunicationMessage> msg) Extract a group communication message object from a message.

Methods in org.apache.reef.io.network.group.impl.utils with parameters of type GroupCommunicationMessage

Modifier and Type	Method and Description
static byte[]	Utils.getData(GroupCommunicationMessage gcm)

Method parameters in org.apache.reef.io.network.group.impl.utils with type arguments of type GroupCommunicationMessage

Modifier and Type	Method and Description
static GroupCommunicationMessage	Utils.getGCM(Message<GroupCommunicationMessage> msg) Extract a group communication message object from a message.