public class GroupCommService extends Object
| Modifier and Type | Class and Description |
|---|---|
class |
GroupCommService.FailedEvaluatorHandler |
class |
GroupCommService.FailedTaskHandler |
class |
GroupCommService.RunningTaskHandler |
| Constructor and Description |
|---|
GroupCommService(GroupCommServiceDriver groupCommDriver) |
| Modifier and Type | Method and Description |
|---|---|
static Configuration |
getConfiguration() |
static Configuration |
getConfiguration(int fanOut) |
@Inject public GroupCommService(GroupCommServiceDriver groupCommDriver)
public static Configuration getConfiguration()
public static Configuration getConfiguration(int fanOut)
Copyright © 2017 The Apache Software Foundation. All rights reserved.