org.apache.reef.io.network.group.impl.task

Class CommunicationGroupClientImpl

java.lang.Object

org.apache.reef.io.network.group.impl.task.CommunicationGroupClientImpl

All Implemented Interfaces:

CommunicationGroupClient, CommunicationGroupServiceClient

public class CommunicationGroupClientImpl
extends Object
implements CommunicationGroupServiceClient

Constructor Summary

Constructors

Constructor and Description
CommunicationGroupClientImpl(String groupName, String taskId, String driverId, GroupCommNetworkHandler groupCommNetworkHandler, Set<String> operatorConfigs, ConfigurationSerializer configSerializer, NetworkService<GroupCommunicationMessage> netService)

Method Summary

Methods

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	initialize() Should not be used by user code Used for initialization of the communication group
void	updateTopology() Asks the driver to update the topology of this communication group.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommunicationGroupClientImpl

@Inject
public CommunicationGroupClientImpl(String groupName,
                                   String taskId,
                                   String driverId,
                                   GroupCommNetworkHandler groupCommNetworkHandler,
                                   Set<String> operatorConfigs,
                                   ConfigurationSerializer configSerializer,
                                   NetworkService<GroupCommunicationMessage> netService)

Method Detail

getBroadcastSender

public Broadcast.Sender getBroadcastSender(Class<? extends Name<String>> operatorName)

Description copied from interface: CommunicationGroupClient

The broadcast sender configured on this communication group with the given oepratorName

Specified by:

getBroadcastSender in interface CommunicationGroupClient

Returns:

getReduceReceiver

public Reduce.Receiver getReduceReceiver(Class<? extends Name<String>> operatorName)

Description copied from interface: CommunicationGroupClient

The reduce receiver configured on this communication group with the given oepratorName

Specified by:

getReduceReceiver in interface CommunicationGroupClient

Returns:

getBroadcastReceiver

public Broadcast.Receiver getBroadcastReceiver(Class<? extends Name<String>> operatorName)

Description copied from interface: CommunicationGroupClient

The broadcast receiver configured on this communication group with the given oepratorName

Specified by:

getBroadcastReceiver in interface CommunicationGroupClient

Returns:

getReduceSender

public Reduce.Sender getReduceSender(Class<? extends Name<String>> operatorName)

Description copied from interface: CommunicationGroupClient

The reduce sender configured on this communication group with the given oepratorName

Specified by:

getReduceSender in interface CommunicationGroupClient

Returns:

initialize

public void initialize()

Description copied from interface: CommunicationGroupServiceClient

Should not be used by user code Used for initialization of the communication group

Specified by:

initialize in interface CommunicationGroupServiceClient

getTopologyChanges

public GroupChanges getTopologyChanges()

Specified by:

getTopologyChanges in interface CommunicationGroupClient

Returns:

Changes in topology of this communication group since the last time this method was called

updateTopology

public void updateTopology()

Description copied from interface: CommunicationGroupClient

Asks the driver to update the topology of this communication group. This can be an expensive call depending on what the minimum number of tasks is for this group to function as this first tells the driver, driver then tells the affected tasks and the driver gives a green only after affected tasks have had a chance to be sure that their topology will be updated before the next message is communicated

Specified by:

updateTopology in interface CommunicationGroupClient

getName

public Class<? extends Name<String>> getName()

Specified by:

getName in interface CommunicationGroupClient

Returns:

The name configured on this communication group