@DefaultImplementation(value=ReduceSender.class) public static interface Reduce.Sender<T> extends GroupCommOperator
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.
|
getGroupName, getOperName, getVersion, initialize
void send(T element) throws NetworkException, InterruptedException
NetworkException
InterruptedException
Reduce.ReduceFunction<T> getReduceFunction()
Reduce.ReduceFunction
to be applied on the set of received values.Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.