@DefaultImplementation(value=GroupCommDriverImpl.class) public interface GroupCommDriver
Modifier and Type | Method and Description |
---|---|
Configuration |
getContextConfiguration() |
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
|
CommunicationGroupDriver newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks)
groupName
- numberOfTasks
- boolean isConfigured(ActiveContext activeContext)
activeContext
- Configuration getContextConfiguration()
Configuration getServiceConfiguration()
Configuration getTaskConfiguration(Configuration partialTaskConf)
Copyright © 2015 The Apache Software Foundation. All rights reserved.