public class CommunicationGroupDriverImpl extends Object implements CommunicationGroupDriver
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.
|
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) |
@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)
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 CommunicationGroupDriver addScatter(Class<? extends Name<String>> operatorName, ScatterOperatorSpec spec)
CommunicationGroupDriver
operatorName
and spec
.addScatter
in interface CommunicationGroupDriver
public CommunicationGroupDriver addGather(Class<? extends Name<String>> operatorName, GatherOperatorSpec spec)
CommunicationGroupDriver
operatorName
and spec
.addGather
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 © 2017 The Apache Software Foundation. All rights reserved.