public class CommunicationGroupDriverImpl extends Object implements CommunicationGroupDriver
Constructor and Description |
---|
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName,
ConfigurationSerializer confSerializer,
EStage<GroupCommunicationMessage> senderStage,
BroadcastingEventHandler<RunningTask> commGroupRunningTaskHandler,
BroadcastingEventHandler<FailedTask> commGroupFailedTaskHandler,
BroadcastingEventHandler<FailedEvaluator> commGroupFailedEvaluatorHandler,
BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
String driverId,
int numberOfTasks,
int fanOut) |
Modifier and Type | Method and Description |
---|---|
CommunicationGroupDriver |
addBroadcast(Class<? extends Name<String>> operatorName,
BroadcastOperatorSpec spec)
Add the broadcast operator specified by the
'spec' with name 'operatorName' into this
Communication Group
|
CommunicationGroupDriver |
addReduce(Class<? extends Name<String>> operatorName,
ReduceOperatorSpec spec)
Add the reduce operator specified by the
'spec' with name 'operatorName' into this
Communication Group
|
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
operator specs will be added to this communication
group and an attempt to do that will throw an
IllegalStateException
|
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) |
public CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> commGroupRunningTaskHandler, BroadcastingEventHandler<FailedTask> commGroupFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> commGroupFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut)
public CommunicationGroupDriver addBroadcast(Class<? extends Name<String>> operatorName, BroadcastOperatorSpec spec)
CommunicationGroupDriver
addBroadcast
in interface CommunicationGroupDriver
public CommunicationGroupDriver addReduce(Class<? extends Name<String>> operatorName, ReduceOperatorSpec spec)
CommunicationGroupDriver
addReduce
in interface CommunicationGroupDriver
public Configuration getTaskConfiguration(Configuration taskConf)
CommunicationGroupDriver
GroupCommClient
getTaskConfiguration
in interface CommunicationGroupDriver
public void finalise()
CommunicationGroupDriver
finalise
in interface CommunicationGroupDriver
public void addTask(Configuration partialTaskConf)
CommunicationGroupDriver
addTask
in interface CommunicationGroupDriver
public void removeTask(String taskId)
public void queNProcessMsg(GroupCommunicationMessage msg)
public void processMsg(GroupCommunicationMessage msg)
Copyright © 2015 The Apache Software Foundation. All rights reserved.