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

Class GroupCommDriverImpl

java.lang.Object

org.apache.reef.io.network.group.impl.driver.GroupCommDriverImpl

All Implemented Interfaces:

GroupCommDriver, GroupCommServiceDriver

public class GroupCommDriverImpl
extends Object
implements GroupCommServiceDriver

Sets up various stages to handle REEF events and adds the per communication group stages to them whenever a new communication group is created.

Also starts the NameService and the NetworkService on the driver

Constructor Summary

Constructors

Constructor and Description
GroupCommDriverImpl(ConfigurationSerializer confSerializer, String driverId, int fanOut, LocalAddressProvider localAddressProvider, TransportFactory tpFactory, NameServer nameService) Deprecated. in 0.12. Use Tang to obtain an instance of this instead.

Method Summary

Methods

Modifier and Type	Method and Description
Configuration	getContextConfiguration()
EStage<FailedEvaluator>	getGroupCommFailedEvaluatorStage() Not user facing but used the Group Communication Service class.
EStage<FailedTask>	getGroupCommFailedTaskStage() Not user facing but used the Group Communication Service class.
EStage<RunningTask>	getGroupCommRunningTaskStage() Not user facing but used the Group Communication Service class.
Configuration	getServiceConfiguration()
Configuration	getTaskConfiguration(Configuration partialTaskConf)
boolean	isConfigured(ActiveContext activeContext) Tests whether the activeContext is a context configured.
CommunicationGroupDriver	newCommunicationGroup(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut) Create a new communication group with the specified name, topology implementation, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.
CommunicationGroupDriver	newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks) Create a new communication group with the specified name.
CommunicationGroupDriver	newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks, int customFanOut) Create a new communication group with the specified name, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupCommDriverImpl

@Deprecated
@Inject
public GroupCommDriverImpl(ConfigurationSerializer confSerializer,
                                     String driverId,
                                     int fanOut,
                                     LocalAddressProvider localAddressProvider,
                                     TransportFactory tpFactory,
                                     NameServer nameService)

Deprecated. in 0.12. Use Tang to obtain an instance of this instead.

Method Detail

newCommunicationGroup

public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName,
                                             int numberOfTasks)

Description copied from interface: GroupCommDriver

Create a new communication group with the specified name. and the minimum number of tasks needed in this group before communication can start

Specified by:

newCommunicationGroup in interface GroupCommDriver

Returns:

newCommunicationGroup

public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName,
                                             int numberOfTasks,
                                             int customFanOut)

Description copied from interface: GroupCommDriver

Create a new communication group with the specified name, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.

Specified by:

newCommunicationGroup in interface GroupCommDriver

Returns:

newCommunicationGroup

public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName,
                                             Class<? extends Topology> topologyClass,
                                             int numberOfTasks,
                                             int customFanOut)

Description copied from interface: GroupCommDriver

Create a new communication group with the specified name, topology implementation, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.

Specified by:

newCommunicationGroup in interface GroupCommDriver

Returns:

isConfigured

public boolean isConfigured(ActiveContext activeContext)

Description copied from interface: GroupCommDriver

Tests whether the activeContext is a context configured. using the Group Communication Service

Specified by:

isConfigured in interface GroupCommDriver

Returns:

getContextConfiguration

public Configuration getContextConfiguration()

Specified by:

getContextConfiguration in interface GroupCommDriver

Returns:

Configuration needed for a Context that should have Group Communication Service enabled

getServiceConfiguration

public Configuration getServiceConfiguration()

Specified by:

getServiceConfiguration in interface GroupCommDriver

Returns:

Configuration needed to enable Group Communication as a Service

getTaskConfiguration

public Configuration getTaskConfiguration(Configuration partialTaskConf)

Specified by:

getTaskConfiguration in interface GroupCommDriver

Returns:

Configuration needed for a Task that should have Group Communication Service enabled

getGroupCommRunningTaskStage

public EStage<RunningTask> getGroupCommRunningTaskStage()

Description copied from interface: GroupCommServiceDriver

Not user facing but used the Group Communication Service class.

Specified by:

getGroupCommRunningTaskStage in interface GroupCommServiceDriver

Returns:

the groupCommRunningTaskStage

getGroupCommFailedTaskStage

public EStage<FailedTask> getGroupCommFailedTaskStage()

Description copied from interface: GroupCommServiceDriver

Not user facing but used the Group Communication Service class.

Specified by:

getGroupCommFailedTaskStage in interface GroupCommServiceDriver

Returns:

the groupCommFailedTaskStage

getGroupCommFailedEvaluatorStage

public EStage<FailedEvaluator> getGroupCommFailedEvaluatorStage()

Description copied from interface: GroupCommServiceDriver

Not user facing but used the Group Communication Service class.

Specified by:

getGroupCommFailedEvaluatorStage in interface GroupCommServiceDriver

Returns:

the groupCommFailedEvaluatorStage