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

Class CommunicationGroupDriverImpl

java.lang.Object

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

All Implemented Interfaces:

CommunicationGroupDriver

public class CommunicationGroupDriverImpl
extends Object
implements CommunicationGroupDriver

Constructor Summary

Constructors

Constructor and Description

CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.

Method Summary

Methods

Modifier and Type	Method and Description
CommunicationGroupDriver	addBroadcast(Class<? extends Name<String>> operatorName, BroadcastOperatorSpec spec) Add the broadcast operator specified by the.
CommunicationGroupDriver	addGather(Class<? extends Name<String>> operatorName, GatherOperatorSpec spec) Add the gather operator specified by operatorName and spec.
CommunicationGroupDriver	addReduce(Class<? extends Name<String>> operatorName, ReduceOperatorSpec spec) Add the reduce operator specified by the.
CommunicationGroupDriver	addScatter(Class<? extends Name<String>> operatorName, ScatterOperatorSpec spec) Add the scatter operator specified by operatorName and spec.
void	addTask(Configuration partialTaskConf) Add the task represented by this configuration to this communication group.
void	failTask(String id)
void	finalise() This signals to the service that no more.
Configuration	getTaskConfiguration(Configuration taskConf) Returns a configuration that includes the partial task configuration passed in as 'taskConf' and makes the current communication group and the operators configured on it available on the Task side.
void	processMsg(GroupCommunicationMessage msg)
void	queNProcessMsg(GroupCommunicationMessage msg)
void	removeTask(String taskId)
void	runTask(String id)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommunicationGroupDriverImpl

@Deprecated
public CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName,
                                       ConfigurationSerializer confSerializer,
                                       EStage<GroupCommunicationMessage> senderStage,
                                       BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler,
                                       BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler,
                                       BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler,
                                       BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
                                       String driverId,
                                       int numberOfTasks,
                                       int fanOut)

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

Method Detail

addBroadcast

public CommunicationGroupDriver addBroadcast(Class<? extends Name<String>> operatorName,
                                    BroadcastOperatorSpec spec)

Description copied from interface: CommunicationGroupDriver

Add the broadcast operator specified by the. 'spec' with name 'operatorName' into this Communication Group

Specified by:

addBroadcast in interface CommunicationGroupDriver

Returns:

addReduce

public CommunicationGroupDriver addReduce(Class<? extends Name<String>> operatorName,
                                 ReduceOperatorSpec spec)

Description copied from interface: CommunicationGroupDriver

Add the reduce operator specified by the. 'spec' with name 'operatorName' into this Communication Group

Specified by:

addReduce in interface CommunicationGroupDriver

Returns:

addScatter

public CommunicationGroupDriver addScatter(Class<? extends Name<String>> operatorName,
                                  ScatterOperatorSpec spec)

Description copied from interface: CommunicationGroupDriver

Add the scatter operator specified by operatorName and spec.

Specified by:

addScatter in interface CommunicationGroupDriver

Returns:

addGather

public CommunicationGroupDriver addGather(Class<? extends Name<String>> operatorName,
                                 GatherOperatorSpec spec)

Description copied from interface: CommunicationGroupDriver

Add the gather operator specified by operatorName and spec.

Specified by:

addGather in interface CommunicationGroupDriver

Returns:

getTaskConfiguration

public Configuration getTaskConfiguration(Configuration taskConf)

Description copied from interface: CommunicationGroupDriver

Returns a configuration that includes the partial task configuration passed in as 'taskConf' and makes the current communication group and the operators configured on it available on the Task side. Provides for injection of GroupCommClient

Specified by:

getTaskConfiguration in interface CommunicationGroupDriver

Returns:

finalise

public void finalise()

Description copied from interface: CommunicationGroupDriver

This signals to the service that no more. operator specs will be added to this communication group and an attempt to do that will throw an IllegalStateException

Specified by:

finalise in interface CommunicationGroupDriver

addTask

public void addTask(Configuration partialTaskConf)

Description copied from interface: CommunicationGroupDriver

Add the task represented by this configuration to this communication group. The configuration needs to contain the id of the Task that will be used

Specified by:

addTask in interface CommunicationGroupDriver

removeTask

public void removeTask(String taskId)

runTask

public void runTask(String id)

failTask

public void failTask(String id)

queNProcessMsg

public void queNProcessMsg(GroupCommunicationMessage msg)

processMsg

public void processMsg(GroupCommunicationMessage msg)