public class GrouperFactory extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
GrouperFactory.AllGrouper |
static class |
GrouperFactory.BasicLoadAwareCustomStreamGrouping
A bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping.
|
static class |
GrouperFactory.FieldsGrouper |
static class |
GrouperFactory.GlobalGrouper |
static class |
GrouperFactory.NoneGrouper |
| Modifier and Type | Field and Description |
|---|---|
static LoadAwareCustomStreamGrouping |
DIRECT |
| Constructor and Description |
|---|
GrouperFactory() |
| Modifier and Type | Method and Description |
|---|---|
static LoadAwareCustomStreamGrouping |
mkGrouper(WorkerTopologyContext context,
String componentId,
String streamId,
Fields outFields,
Grouping thriftGrouping,
List<Integer> unsortedTargetTasks,
Map<String,Object> topoConf) |
public static final LoadAwareCustomStreamGrouping DIRECT
Copyright © 2021 The Apache Software Foundation. All rights reserved.