Package | Description |
---|---|
backtype.storm.drpc | |
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 |
NGrouping |
Modifier and Type | Method and Description |
---|---|
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
CustomStreamGrouping grouping) |
T |
InputDeclarer.customGrouping(String componentId,
CustomStreamGrouping grouping) |
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
String streamId,
CustomStreamGrouping grouping) |
T |
InputDeclarer.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 © 2016 The Apache Software Foundation. All Rights Reserved.