| Package | Description |
|---|---|
| backtype.storm.drpc | |
| backtype.storm.grouping | |
| backtype.storm.testing | |
| backtype.storm.topology | |
| storm.trident | |
| storm.trident.partition |
| Modifier and Type | Method and Description |
|---|---|
LinearDRPCInputDeclarer |
LinearDRPCInputDeclarer.customGrouping(CustomStreamGrouping grouping) |
LinearDRPCInputDeclarer |
LinearDRPCInputDeclarer.customGrouping(String streamId,
CustomStreamGrouping grouping) |
| Modifier and Type | Class and Description |
|---|---|
class |
PartialKeyGrouping |
| 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) |
| Modifier and Type | Class and Description |
|---|---|
class |
GlobalGrouping |
class |
IdentityGrouping |
class |
IndexHashGrouping |
Copyright © 2015. All rights reserved.