org.apache.reef.io.network.group.impl.operators

Class GatherSender<T>

java.lang.Object

org.apache.reef.io.network.group.impl.operators.GatherSender<T>

All Implemented Interfaces:

Gather.Sender<T>, GroupCommOperator, EventHandler<GroupCommunicationMessage>

public class GatherSender<T>
extends Object
implements Gather.Sender<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

Constructor and Description
GatherSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)

Method Summary

Methods

Modifier and Type	Method and Description
Class<? extends Name<String>>	getGroupName()
Class<? extends Name<String>>	getOperName()
int	getVersion()
void	initialize()
void	onNext(GroupCommunicationMessage msg) Handles an event.
void	send(T myData) Send the element to the root/receiver.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GatherSender

@Inject
public GatherSender(String groupName,
                   String operName,
                   String selfId,
                   Codec<T> dataCodec,
                   String driverId,
                   int version,
                   CommGroupNetworkHandler commGroupNetworkHandler,
                   NetworkService<GroupCommunicationMessage> netService,
                   CommunicationGroupServiceClient commGroupClient)

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface GroupCommOperator

initialize

public void initialize()
                throws ParentDeadException

Specified by:

initialize in interface GroupCommOperator

Throws:

ParentDeadException

getOperName

public Class<? extends Name<String>> getOperName()

Specified by:

getOperName in interface GroupCommOperator

getGroupName

public Class<? extends Name<String>> getGroupName()

Specified by:

getGroupName in interface GroupCommOperator

toString

public String toString()

Overrides:

toString in class Object

onNext

public void onNext(GroupCommunicationMessage msg)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<GroupCommunicationMessage>

Parameters:

msg - an event

send

public void send(T myData)
          throws NetworkException,
                 InterruptedException

Description copied from interface: Gather.Sender

Send the element to the root/receiver.

Specified by:

send in interface Gather.Sender<T>

Throws:

NetworkException

InterruptedException