public interface CommunicationGroupDriver
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 |
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.
|
CommunicationGroupDriver addBroadcast(Class<? extends Name<String>> operatorName, BroadcastOperatorSpec spec)
operatorName
- spec
- CommunicationGroupDriver addReduce(Class<? extends Name<String>> operatorName, ReduceOperatorSpec spec)
operatorName
- spec
- void finalise()
Configuration getTaskConfiguration(Configuration taskConf)
GroupCommClient
taskConf
- void addTask(Configuration partialTaskConf)
partialTaskConf
- Copyright © 2015 The Apache Software Foundation. All rights reserved.