| Modifier and Type | Class and Description |
|---|---|
class |
Murmur3StreamGrouping
Simple
CustomStreamGrouping that uses Murmur3 algorithm to choose the target task of a tuple. |
| 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 |
| Constructor and Description |
|---|
BasicLoadAwareCustomStreamGrouping(CustomStreamGrouping customStreamGrouping) |
| Modifier and Type | Method and Description |
|---|---|
LinearDRPCInputDeclarer |
LinearDRPCInputDeclarer.customGrouping(CustomStreamGrouping grouping) |
LinearDRPCInputDeclarer |
LinearDRPCInputDeclarer.customGrouping(String streamId,
CustomStreamGrouping grouping) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
LoadAwareCustomStreamGrouping |
| Modifier and Type | Class and Description |
|---|---|
class |
LoadAwareShuffleGrouping |
class |
PartialKeyGrouping
A variation on FieldGrouping.
|
class |
ShuffleGrouping |
| Modifier and Type | Class and Description |
|---|---|
class |
NGrouping |
| Modifier and Type | Method and Description |
|---|---|
T |
InputDeclarer.customGrouping(String componentId,
CustomStreamGrouping grouping)
A custom stream grouping by implementing the CustomStreamGrouping interface.
|
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
CustomStreamGrouping grouping) |
T |
InputDeclarer.customGrouping(String componentId,
String streamId,
CustomStreamGrouping grouping)
A custom stream grouping by implementing the CustomStreamGrouping interface.
|
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
String streamId,
CustomStreamGrouping grouping) |
| Modifier and Type | Method and Description |
|---|---|
Stream |
Stream.partition(CustomStreamGrouping partitioner)
Repartitioning Operation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GlobalGrouping |
class |
IdentityGrouping |
class |
IndexHashGrouping |
Copyright © 2021 The Apache Software Foundation. All rights reserved.