@DefaultImplementation(value=CommunicationGroupClientImpl.class) public interface CommunicationGroupClient
Modifier and Type | Method and Description |
---|---|
List<Identifier> |
getActiveSlaveTasks() |
Broadcast.Receiver |
getBroadcastReceiver(Class<? extends Name<String>> operatorName)
The broadcast receiver configured on this communication group.
|
Broadcast.Sender |
getBroadcastSender(Class<? extends Name<String>> operatorName)
The broadcast sender configured on this communication group.
|
Gather.Receiver |
getGatherReceiver(Class<? extends Name<String>> operatorName)
Return the gather receiver configured on this communication group.
|
Gather.Sender |
getGatherSender(Class<? extends Name<String>> operatorName)
Return the gather sender configured on this communication group.
|
Class<? extends Name<String>> |
getName() |
Reduce.Receiver |
getReduceReceiver(Class<? extends Name<String>> operatorName)
The reduce receiver configured on this communication group.
|
Reduce.Sender |
getReduceSender(Class<? extends Name<String>> operatorName)
The reduce sender configured on this communication group.
|
Scatter.Receiver |
getScatterReceiver(Class<? extends Name<String>> operatorName)
Return the scatter receiver configured on this communication group.
|
Scatter.Sender |
getScatterSender(Class<? extends Name<String>> operatorName)
Return the scatter sender configured on this communication group.
|
GroupChanges |
getTopologyChanges() |
TopologySimpleNode |
getTopologySimpleNodeRoot() |
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
- Scatter.Sender getScatterSender(Class<? extends Name<String>> operatorName)
operatorName
is used to specify the scatter sender to return.operatorName
- Scatter.Receiver getScatterReceiver(Class<? extends Name<String>> operatorName)
operatorName
is used to specify the scatter receiver to return.operatorName
- Gather.Receiver getGatherReceiver(Class<? extends Name<String>> operatorName)
operatorName
is used to specify the gather receiver to return.operatorName
- Gather.Sender getGatherSender(Class<? extends Name<String>> operatorName)
operatorName
is used to specify the gather sender to return.operatorName
- GroupChanges getTopologyChanges()
List<Identifier> getActiveSlaveTasks()
TopologySimpleNode getTopologySimpleNodeRoot()
void updateTopology()
Copyright © 2017 The Apache Software Foundation. All rights reserved.