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.