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

Class ReduceReceiver<T>

java.lang.Object

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

All Implemented Interfaces:

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

public class ReduceReceiver<T>
extends Object
implements Reduce.Receiver<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

Constructor and Description
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)

Method Summary

Methods

Modifier and Type	Method and Description
Class<? extends Name<String>>	getGroupName()
Class<? extends Name<String>>	getOperName()
Reduce.ReduceFunction<T>	getReduceFunction() The reduce function to be applied on the set of received values.
int	getVersion()
void	initialize()
void	onNext(GroupCommunicationMessage msg) Handles an event.
T	reduce() Receive values sent by senders and pass them through the reduce function in default order.
T	reduce(List<? extends Identifier> order) Receive values sent by senders and pass them through the reduce function in specified order.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceReceiver

@Inject
public 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)

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

reduce

public T reduce()
         throws InterruptedException,
                NetworkException

Description copied from interface: Reduce.Receiver

Receive values sent by senders and pass them through the reduce function in default order.

Specified by:

reduce in interface Reduce.Receiver<T>

Returns:

Result of applying reduce function on the elements gathered in default order.

Throws:

InterruptedException

NetworkException

reduce

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

Description copied from interface: Reduce.Receiver

Receive values sent by senders and pass them through the reduce function in specified order.

Specified by:

reduce in interface Reduce.Receiver<T>

Returns:

Result of applying reduce function on the elements gathered in specified order.

Throws:

InterruptedException

NetworkException

getReduceFunction

public Reduce.ReduceFunction<T> getReduceFunction()

Description copied from interface: Reduce.Receiver

The reduce function to be applied on the set of received values.

Specified by:

getReduceFunction in interface Reduce.Receiver<T>

Returns:

Reduce.ReduceFunction