public class GroupCommDriverImpl extends Object implements GroupCommServiceDriver
Constructor and Description |
---|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut)
Deprecated.
Have an instance injected instead.
|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut,
LocalAddressProvider localAddressProvider)
Deprecated.
Have an instance injected instead.
|
Modifier and Type | Method and Description |
---|---|
Configuration |
getContextConfiguration() |
EStage<FailedEvaluator> |
getGroupCommFailedEvaluatorStage()
Not user facing but used the Group Communication Service class
|
EStage<FailedTask> |
getGroupCommFailedTaskStage()
Not user facing but used the Group Communication Service class
|
EStage<RunningTask> |
getGroupCommRunningTaskStage()
Not user facing but used the Group Communication Service class
|
Configuration |
getServiceConfiguration() |
Configuration |
getTaskConfiguration(Configuration partialTaskConf) |
boolean |
isConfigured(ActiveContext activeContext)
Tests whether the activeContext is a context configured
using the Group Communication Service
|
CommunicationGroupDriver |
newCommunicationGroup(Class<? extends Name<String>> groupName,
int numberOfTasks)
Create a new communication group with the specified name
and the minimum number of tasks needed in this group before
communication can start
|
@Deprecated @Inject public GroupCommDriverImpl(ConfigurationSerializer confSerializer, String driverId, int fanOut)
@Deprecated @Inject public GroupCommDriverImpl(ConfigurationSerializer confSerializer, String driverId, int fanOut, LocalAddressProvider localAddressProvider)
public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks)
GroupCommDriver
newCommunicationGroup
in interface GroupCommDriver
public boolean isConfigured(ActiveContext activeContext)
GroupCommDriver
isConfigured
in interface GroupCommDriver
public Configuration getContextConfiguration()
getContextConfiguration
in interface GroupCommDriver
public Configuration getServiceConfiguration()
getServiceConfiguration
in interface GroupCommDriver
public Configuration getTaskConfiguration(Configuration partialTaskConf)
getTaskConfiguration
in interface GroupCommDriver
public EStage<RunningTask> getGroupCommRunningTaskStage()
GroupCommServiceDriver
getGroupCommRunningTaskStage
in interface GroupCommServiceDriver
public EStage<FailedTask> getGroupCommFailedTaskStage()
GroupCommServiceDriver
getGroupCommFailedTaskStage
in interface GroupCommServiceDriver
public EStage<FailedEvaluator> getGroupCommFailedEvaluatorStage()
GroupCommServiceDriver
getGroupCommFailedEvaluatorStage
in interface GroupCommServiceDriver
Copyright © 2015 The Apache Software Foundation. All rights reserved.