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 © 2022 The Apache Software Foundation. All rights reserved.