@DefaultImplementation(value=ReduceReceiver.class) public static interface Reduce.Receiver<T> extends GroupCommOperator
Modifier and Type | Method and Description |
---|---|
Reduce.ReduceFunction<T> |
getReduceFunction()
The reduce function to be applied on the set of received values.
|
T |
reduce()
Receive values sent by senders and pass them through the reduce
function in default order.
|
T |
reduce(List<? extends Identifier> order)
Receive values sent by senders and pass them through the reduce
function in specified order.
|
getGroupName, getOperName, getVersion, initialize
T reduce() throws InterruptedException, NetworkException
InterruptedException
NetworkException
T reduce(List<? extends Identifier> order) throws InterruptedException, NetworkException
InterruptedException
NetworkException
Reduce.ReduceFunction<T> getReduceFunction()
Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.