Helper class to start Group Communication tasks. More...

Public Member Functions
	TaskStarter (IGroupCommDriver groupCommDriver, int numTasks)
	Create new TaskStarter. More...

void	QueueTask (IConfiguration partialTaskConfig, IActiveContext activeContext)
	Queues the task into the TaskStarter. More...

Detailed Description

Helper class to start Group Communication tasks.

Constructor & Destructor Documentation

Org.Apache.REEF.Network.Group.Driver.Impl.TaskStarter.TaskStarter	(	IGroupCommDriver	groupCommDriver,
		int	numTasks
	)

inline

Create new TaskStarter.

After adding the correct number of tasks to the TaskStarter, the Tasks will be started on their given active context.

Parameters

groupCommDriver	The IGroupCommuDriver for the Group Communication tasks
numTasks	The number of Tasks that need to be added before the Tasks will be started.

void Org.Apache.REEF.Network.Group.Driver.Impl.TaskStarter.QueueTask	(	IConfiguration	partialTaskConfig,
		IActiveContext	activeContext
	)

inline

Queues the task into the TaskStarter.

Once the correct number of tasks have been queued, the final Configuration will be generated and run on the given Active Context.

Parameters

partialTaskConfig	The partial task configuration containing Task identifier and Task class
activeContext	The Active Context to run the Task on

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