public class CommunicationGroupClientImpl extends Object implements CommunicationGroupServiceClient
Constructor and Description |
---|
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
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.
|
@Deprecated @Inject public CommunicationGroupClientImpl(String groupName, String taskId, String driverId, GroupCommNetworkHandler groupCommNetworkHandler, Set<String> operatorConfigs, ConfigurationSerializer configSerializer, NetworkService<GroupCommunicationMessage> netService)
injector
as a parameter instead.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 © 2016 The Apache Software Foundation. All rights reserved.