Uses of Interface
org.apache.storm.grouping.CustomStreamGrouping

Packages that use CustomStreamGrouping

Package	Description
org.apache.storm.cassandra
org.apache.storm.drpc
org.apache.storm.grouping
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.trident
org.apache.storm.trident.partition

Uses of CustomStreamGrouping in org.apache.storm.cassandra

Classes in org.apache.storm.cassandra that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	Murmur3StreamGrouping Simple CustomStreamGrouping that uses Murmur3 algorithm to choose the target task of a tuple.

Uses of CustomStreamGrouping in org.apache.storm.drpc

Methods in org.apache.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 org.apache.storm.grouping

Subinterfaces of CustomStreamGrouping in org.apache.storm.grouping

Modifier and Type	Interface and Description
interface	LoadAwareCustomStreamGrouping

Classes in org.apache.storm.grouping that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	LoadAwareShuffleGrouping
class	PartialKeyGrouping
class	ShuffleGrouping

Uses of CustomStreamGrouping in org.apache.storm.testing

Classes in org.apache.storm.testing that implement CustomStreamGrouping

Modifier and Type	Class and Description
class	NGrouping

Uses of CustomStreamGrouping in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type CustomStreamGrouping

Modifier and Type	Method and Description
BoltDeclarer	TopologyBuilder.BoltGetter.customGrouping(String componentId, CustomStreamGrouping grouping)
T	InputDeclarer.customGrouping(String componentId, CustomStreamGrouping grouping) A custom stream grouping by implementing the CustomStreamGrouping interface.
BoltDeclarer	TopologyBuilder.BoltGetter.customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)
T	InputDeclarer.customGrouping(String componentId, String streamId, CustomStreamGrouping grouping) A custom stream grouping by implementing the CustomStreamGrouping interface.

Uses of CustomStreamGrouping in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type CustomStreamGrouping

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

Uses of CustomStreamGrouping in org.apache.storm.trident.partition

Classes in org.apache.storm.trident.partition that implement CustomStreamGrouping

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