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

Class ScatterReceiver<T>

java.lang.Object

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

All Implemented Interfaces:

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

public final class ScatterReceiver<T>
extends Object
implements Scatter.Receiver<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

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

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 sub-list of elements targeted for the current receiver.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScatterReceiver

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

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: Scatter.Receiver

Receive the sub-list of elements targeted for the current receiver.

Specified by:

receive in interface Scatter.Receiver<T>

Returns:

list of elements targeted for the current receiver.

Throws:

NetworkException

InterruptedException