Uses of Interface
backtype.storm.grouping.CustomStreamGrouping

Packages that use CustomStreamGrouping

Package	Description
backtype.storm.drpc
backtype.storm.grouping
backtype.storm.testing
backtype.storm.topology
storm.trident
storm.trident.partition

Uses of CustomStreamGrouping in backtype.storm.drpc

Methods in backtype.storm.drpc with parameters of type CustomStreamGrouping

Modifier and Type	Method and Description
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.customGrouping(CustomStreamGrouping grouping)
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.customGrouping(String streamId, CustomStreamGrouping grouping)

Uses of CustomStreamGrouping in backtype.storm.grouping

Classes in backtype.storm.grouping that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	PartialKeyGrouping

Uses of CustomStreamGrouping in backtype.storm.testing

Classes in backtype.storm.testing that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	NGrouping

Uses of CustomStreamGrouping in backtype.storm.topology

Methods in backtype.storm.topology with parameters of type CustomStreamGrouping

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)

Uses of CustomStreamGrouping in storm.trident

Methods in storm.trident with parameters of type CustomStreamGrouping

Modifier and Type	Method and Description
Stream	Stream.partition(CustomStreamGrouping partitioner)

Uses of CustomStreamGrouping in storm.trident.partition

Classes in storm.trident.partition that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	GlobalGrouping
class	IdentityGrouping
class	IndexHashGrouping