public final class GroupCommDriverImpl extends Object implements GroupCommServiceDriver
Also starts the NameService and the NetworkService on the driver
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.
|
CommunicationGroupDriver |
newCommunicationGroup(Class<? extends Name<String>> groupName,
Class<? extends Topology> topologyClass,
int numberOfTasks,
int customFanOut)
Create a new communication group with the specified name, topology implementation,
the minimum number of tasks needed in this group before
communication can start, and a custom fanOut.
|
CommunicationGroupDriver |
newCommunicationGroup(Class<? extends Name<String>> groupName,
int numberOfTasks)
Create a new communication group with the specified name.
|
CommunicationGroupDriver |
newCommunicationGroup(Class<? extends Name<String>> groupName,
int numberOfTasks,
int customFanOut)
Create a new communication group with the specified name,
the minimum number of tasks needed in this group before
communication can start, and a custom fanOut.
|
public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks)
GroupCommDriver
newCommunicationGroup
in interface GroupCommDriver
public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks, int customFanOut)
GroupCommDriver
newCommunicationGroup
in interface GroupCommDriver
public CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut)
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 © 2017 The Apache Software Foundation. All rights reserved.