public class ReduceReceiver<T> extends Object implements Reduce.Receiver<T>, EventHandler<GroupCommunicationMessage>
Constructor and Description |
---|
ReduceReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
Reduce.ReduceFunction<T> reduceFunction,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Name<String>> |
getGroupName() |
Class<? extends Name<String>> |
getOperName() |
Reduce.ReduceFunction<T> |
getReduceFunction()
The reduce function to be applied on the set of received values.
|
int |
getVersion() |
void |
initialize() |
void |
onNext(GroupCommunicationMessage msg)
Handles an event.
|
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.
|
String |
toString() |
@Inject public ReduceReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
public int getVersion()
getVersion
in interface GroupCommOperator
public void initialize() throws ParentDeadException
initialize
in interface GroupCommOperator
ParentDeadException
public Class<? extends Name<String>> getOperName()
getOperName
in interface GroupCommOperator
public Class<? extends Name<String>> getGroupName()
getGroupName
in interface GroupCommOperator
public void onNext(GroupCommunicationMessage msg)
EventHandler
onNext
in interface EventHandler<GroupCommunicationMessage>
msg
- an eventpublic T reduce() throws InterruptedException, NetworkException
Reduce.Receiver
reduce
in interface Reduce.Receiver<T>
InterruptedException
NetworkException
public T reduce(List<? extends Identifier> order) throws InterruptedException, NetworkException
Reduce.Receiver
reduce
in interface Reduce.Receiver<T>
InterruptedException
NetworkException
public Reduce.ReduceFunction<T> getReduceFunction()
Reduce.Receiver
getReduceFunction
in interface Reduce.Receiver<T>
Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.