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

Interface ReduceScatter<T>

All Superinterfaces:

GroupCommOperator

public interface ReduceScatter<T>
extends GroupCommOperator

MPI Reduce Scatter operator.

Each task has a list of elements. Assume that each task reduces each element in the list to form a list of reduced elements at a dummy root. The dummy root then keeps the portion of the list assigned to it and scatters the remaining among the other tasks

Method Summary

Methods

Modifier and Type	Method and Description
List<T>	apply(List<T> elements, List<Integer> counts) Apply this operation on elements where counts specify the distribution of elements to each task.
List<T>	apply(List<T> elements, List<Integer> counts, List<? extends Identifier> order) Apply this operation on elements where counts specify the distribution of elements to each task.
Reduce.ReduceFunction<T>	getReduceFunction() get Reduce.ReduceFunction configured.

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

getGroupName, getOperName, getVersion, initialize

Method Detail

apply

List<T> apply(List<T> elements,
            List<Integer> counts)
              throws InterruptedException,
                     NetworkException

Apply this operation on elements where counts specify the distribution of elements to each task. Ordering is assumed to be default.

Here counts is of the same size as the entire group not just children.

Returns:

List of values that result from applying reduce function on corresponding elements of each list received as a result of applying scatter.

Throws:

InterruptedException

NetworkException

apply

List<T> apply(List<T> elements,
            List<Integer> counts,
            List<? extends Identifier> order)
              throws InterruptedException,
                     NetworkException

Apply this operation on elements where counts specify the distribution of elements to each task. Ordering is specified using order

Here counts is of the same size as the entire group not just children

Returns:

List of values that result from applying reduce function on corresponding elements of each list received as a result of applying scatter.

Throws:

InterruptedException

NetworkException

getReduceFunction

Reduce.ReduceFunction<T> getReduceFunction()

get Reduce.ReduceFunction configured.

Returns:

Reduce.ReduceFunction