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 final 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

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

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