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

Class GatherReceiver<T>

java.lang.Object

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

All Implemented Interfaces:

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

public class GatherReceiver<T>
extends Object
implements Gather.Receiver<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

Constructor and Description
GatherReceiver(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.
List<T>	receive() Receive the elements sent by the senders in default order.
List<T>	receive(List<? extends Identifier> order) Receive the elements sent by the senders in specified order.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

GatherReceiver

@Inject
public GatherReceiver(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

receive

public List<T> receive()
                throws NetworkException,
                       InterruptedException

Description copied from interface: Gather.Receiver

Receive the elements sent by the senders in default order.

Specified by:

receive in interface Gather.Receiver<T>

Returns:

elements sent by senders as a List in default order

Throws:

NetworkException

InterruptedException

receive

public List<T> receive(List<? extends Identifier> order)
                throws NetworkException,
                       InterruptedException

Description copied from interface: Gather.Receiver

Receive the elements sent by the senders in specified order.

Specified by:

receive in interface Gather.Receiver<T>

Returns:

elements sent by senders as a List in specified order

Throws:

NetworkException

InterruptedException