@DefaultImplementation(value=CommunicationGroupClientImpl.class) public interface CommunicationGroupClient
Modifier and Type | Method and Description |
---|---|
Broadcast.Receiver |
getBroadcastReceiver(Class<? extends Name<String>> operatorName)
The broadcast receiver configured on this communication group
with the given oepratorName
|
Broadcast.Sender |
getBroadcastSender(Class<? extends Name<String>> operatorName)
The broadcast sender configured on this communication group
with the given oepratorName
|
Class<? extends Name<String>> |
getName() |
Reduce.Receiver |
getReduceReceiver(Class<? extends Name<String>> operatorName)
The reduce receiver configured on this communication group
with the given oepratorName
|
Reduce.Sender |
getReduceSender(Class<? extends Name<String>> operatorName)
The reduce sender configured on this communication group
with the given oepratorName
|
GroupChanges |
getTopologyChanges() |
void |
updateTopology()
Asks the driver to update the topology of this communication group.
|
Class<? extends Name<String>> getName()
Broadcast.Sender getBroadcastSender(Class<? extends Name<String>> operatorName)
operatorName
- Broadcast.Receiver getBroadcastReceiver(Class<? extends Name<String>> operatorName)
operatorName
- Reduce.Receiver getReduceReceiver(Class<? extends Name<String>> operatorName)
operatorName
- Reduce.Sender getReduceSender(Class<? extends Name<String>> operatorName)
operatorName
- GroupChanges getTopologyChanges()
void updateTopology()
Copyright © 2015 The Apache Software Foundation. All rights reserved.