public final class CommunicationGroupClientImpl extends Object implements CommunicationGroupServiceClient
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 |
initialize()
Should not be used by user code.
|
void |
updateTopology()
Asks the driver to update the topology of this communication group.
|
public Broadcast.Sender getBroadcastSender(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
getBroadcastSender
in interface CommunicationGroupClient
public Reduce.Receiver getReduceReceiver(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
getReduceReceiver
in interface CommunicationGroupClient
public Scatter.Sender getScatterSender(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
operatorName
is used to specify the scatter sender to return.getScatterSender
in interface CommunicationGroupClient
public Gather.Receiver getGatherReceiver(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
operatorName
is used to specify the gather receiver to return.getGatherReceiver
in interface CommunicationGroupClient
public Broadcast.Receiver getBroadcastReceiver(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
getBroadcastReceiver
in interface CommunicationGroupClient
public Reduce.Sender getReduceSender(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
getReduceSender
in interface CommunicationGroupClient
public Scatter.Receiver getScatterReceiver(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
operatorName
is used to specify the scatter receiver to return.getScatterReceiver
in interface CommunicationGroupClient
public Gather.Sender getGatherSender(Class<? extends Name<String>> operatorName)
CommunicationGroupClient
operatorName
is used to specify the gather sender to return.getGatherSender
in interface CommunicationGroupClient
public void initialize()
CommunicationGroupServiceClient
initialize
in interface CommunicationGroupServiceClient
public GroupChanges getTopologyChanges()
getTopologyChanges
in interface CommunicationGroupClient
public void updateTopology()
CommunicationGroupClient
updateTopology
in interface CommunicationGroupClient
public List<Identifier> getActiveSlaveTasks()
getActiveSlaveTasks
in interface CommunicationGroupClient
public TopologySimpleNode getTopologySimpleNodeRoot()
getTopologySimpleNodeRoot
in interface CommunicationGroupClient
Copyright © 2017 The Apache Software Foundation. All rights reserved.