public interface AllReduce<T> extends GroupCommOperator
Modifier and Type | Method and Description |
---|---|
T |
apply(T aElement)
Apply the operation on element.
|
T |
apply(T element,
List<? extends Identifier> order)
Apply the operation on element.
|
Reduce.ReduceFunction<T> |
getReduceFunction()
Get the
Reduce.ReduceFunction configured. |
getGroupName, getOperName, getVersion, initialize
T apply(T aElement) throws InterruptedException, NetworkException
InterruptedException
NetworkException
T apply(T element, List<? extends Identifier> order) throws InterruptedException, NetworkException
InterruptedException
NetworkException
Reduce.ReduceFunction<T> getReduceFunction()
Reduce.ReduceFunction
configured.Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.