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

Interface Reduce.Sender<T>

All Superinterfaces:

GroupCommOperator

All Known Implementing Classes:

ReduceSender

Enclosing interface:

Reduce

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

Senders or non roots.

Method Summary

Methods

Modifier and Type	Method and Description
Reduce.ReduceFunction<T>	getReduceFunction() The Reduce.ReduceFunction to be applied on the set of received values.
void	send(T element) Send the element to the root.

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

getGroupName, getOperName, getVersion, initialize

Method Detail

send

void send(T element)
          throws NetworkException,
                 InterruptedException

Send the element to the root.

Throws:

NetworkException

InterruptedException

getReduceFunction

Reduce.ReduceFunction<T> getReduceFunction()

The Reduce.ReduceFunction to be applied on the set of received values.

Returns:

Reduce.ReduceFunction