public class ReduceSender<T> extends Object implements Reduce.Sender<T>, EventHandler<GroupCommunicationMessage>
Constructor and Description |
---|
ReduceSender(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.ReduceFunction to be applied on the set of received values. |
int |
getVersion() |
void |
initialize() |
void |
onNext(GroupCommunicationMessage msg)
Handles an event.
|
void |
send(T myData)
Send the element to the root.
|
String |
toString() |
@Inject public ReduceSender(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 void send(T myData) throws NetworkException, InterruptedException
Reduce.Sender
send
in interface Reduce.Sender<T>
NetworkException
InterruptedException
public Reduce.ReduceFunction<T> getReduceFunction()
Reduce.Sender
Reduce.ReduceFunction
to be applied on the set of received values.getReduceFunction
in interface Reduce.Sender<T>
Reduce.ReduceFunction
Copyright © 2017 The Apache Software Foundation. All rights reserved.