public interface ReduceScatter<T> extends GroupCommOperator
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
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. |
getGroupName, getOperName, getVersion, initialize
List<T> apply(List<T> elements, List<Integer> counts) throws InterruptedException, NetworkException
Here counts is of the same size as the entire group not just children.
InterruptedException
NetworkException
List<T> apply(List<T> elements, List<Integer> counts, List<? extends Identifier> order) throws InterruptedException, NetworkException
Here counts is of the same size as the entire group not just children
InterruptedException
NetworkException
Reduce.ReduceFunction<T> getReduceFunction()
Reduce.ReduceFunction
configured.Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.