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

Interface Reduce.Receiver<T>

All Superinterfaces:

GroupCommOperator

All Known Implementing Classes:

ReduceReceiver

Enclosing interface:

Reduce

@DefaultImplementation(value=ReduceReceiver.class)
public static interface Reduce.Receiver<T>
extends GroupCommOperator

Receiver or Root.

Method Summary

Methods

Modifier and Type	Method and Description
Reduce.ReduceFunction<T>	getReduceFunction() The reduce function to be applied on the set of received values.
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.

Methods inherited from interface org.apache.reef.io.network.group.api.operators.GroupCommOperator

getGroupName, getOperName, getVersion, initialize

Method Detail

reduce

T reduce()
         throws InterruptedException,
                NetworkException

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

Returns:

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

Throws:

InterruptedException

NetworkException

reduce

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

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

Returns:

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

Throws:

InterruptedException

NetworkException

getReduceFunction

Reduce.ReduceFunction<T> getReduceFunction()

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

Returns:

Reduce.ReduceFunction