Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver Class Reference

Used to create Communication Groups for Group Communication Operators on the Reef driver. More...

Inherits Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

Public Member Functions
ICommunicationGroupDriver	NewCommunicationGroup (string groupName, int numTasks)
	Create a new CommunicationGroup with the given name and number of tasks/operators. More...
void	RemoveCommunicationGroup (string groupName)
	Remove a group from the GroupCommDriver Throw ArgumentException if the group does not exist More...
IConfiguration	GetContextConfiguration ()
	Generates context configuration with a unique identifier. More...
IConfiguration	GetServiceConfiguration ()
	Get the service configuration required for running Group Communication on Reef tasks. More...
IConfiguration	GetGroupCommTaskConfiguration (string taskId)
	Get the configuration for a particular task. More...
bool	IsMasterTaskContext (IActiveContext activeContext)
	Checks whether this active context can be used to run the Master Task. More...
bool	IsMasterContextConfiguration (IConfiguration contextConfiguration)
	Checks whether this context configuration is used to configure the Master Task. More...
int	GetContextNum (IActiveContext activeContext)
	Gets the context number associated with the Active Context id. More...

Properties
string	MasterTaskId [get]
	Returns the identifier for the master task More...
ICommunicationGroupDriver	DefaultGroup [get]
Properties inherited from Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver
string	MasterTaskId [get]
	Returns the identifier for the master task More...
ICommunicationGroupDriver	DefaultGroup [get]

Detailed Description

Used to create Communication Groups for Group Communication Operators on the Reef driver.

Also manages configuration for Group Communication tasks/services.

Member Function Documentation

IConfiguration Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.GetContextConfiguration ( )

inline

Generates context configuration with a unique identifier.

Returns

The configured context configuration

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

int Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.GetContextNum ( IActiveContext  activeContext )

inline

Gets the context number associated with the Active Context id.

Parameters

activeContext

The active context to check

Returns

The context number associated with the active context id

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

IConfiguration Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.GetGroupCommTaskConfiguration ( string  taskId )

inline

Get the configuration for a particular task.

The task may belong to many Communication Groups, so each one is serialized in the configuration as a SerializedGroupConfig. The user must merge their part of task configuration (task id, task class) with this returned Group Communication task configuration.

Parameters

taskId

The id of the task Configuration to generate

Returns

The Group Communication task configuration with communication group and operator configuration set.

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

IConfiguration Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.GetServiceConfiguration ( )

inline

Get the service configuration required for running Group Communication on Reef tasks.

Returns

The service configuration for the Reef tasks

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

bool Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.IsMasterContextConfiguration ( IConfiguration  contextConfiguration )

inline

Checks whether this context configuration is used to configure the Master Task.

Parameters

contextConfiguration

The context configuration to check

Returns

True if the context configuration is used to configure the Master Task, otherwise false.

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

bool Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.IsMasterTaskContext ( IActiveContext  activeContext )

inline

Checks whether this active context can be used to run the Master Task.

Parameters

activeContext

The active context to check

Returns

True if the active context can run the Master task, otherwise false.

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

ICommunicationGroupDriver Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.NewCommunicationGroup ( string  groupName, int  numTasks  )

inline

Create a new CommunicationGroup with the given name and number of tasks/operators.

Parameters

groupName	The new group name
numTasks	The number of tasks/operators in the group.

Returns

The new Communication Group

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

void Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.RemoveCommunicationGroup ( string  groupName )

inline

Remove a group from the GroupCommDriver Throw ArgumentException if the group does not exist

Parameters

groupName

Implements Org.Apache.REEF.Network.Group.Driver.IGroupCommDriver.

Property Documentation

ICommunicationGroupDriver Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.DefaultGroup

get

string Org.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver.MasterTaskId

get

Returns the identifier for the master task

---

The documentation for this class was generated from the following file:

• lang/cs/Org.Apache.REEF.Network/Group/Driver/Impl/GroupCommDriver.cs