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

Packages that use CustomStreamGrouping

Package	Description
org.apache.storm.daemon
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.daemon

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

Modifier and Type	Class	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

Constructors in org.apache.storm.daemon with parameters of type CustomStreamGrouping

Modifier	Constructor	Description
	BasicLoadAwareCustomStreamGrouping(CustomStreamGrouping customStreamGrouping)

Uses of CustomStreamGrouping in org.apache.storm.drpc

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

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

Uses of CustomStreamGrouping in org.apache.storm.grouping

Subinterfaces of CustomStreamGrouping in org.apache.storm.grouping

Modifier and Type	Interface	Description
interface	LoadAwareCustomStreamGrouping

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

Modifier and Type	Class	Description
class	LoadAwareShuffleGrouping
class	PartialKeyGrouping	A variation on FieldGrouping.
class	ShuffleGrouping

Uses of CustomStreamGrouping in org.apache.storm.testing

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

Modifier and Type	Class	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	Description
T	InputDeclarer.customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)	A custom stream grouping by implementing the CustomStreamGrouping interface.
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)
BoltDeclarer	TopologyBuilder.BoltGetter.customGrouping(String componentId, CustomStreamGrouping grouping)

Uses of CustomStreamGrouping in org.apache.storm.trident

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

Modifier and Type	Method	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	Description
class	GlobalGrouping
class	IdentityGrouping
class	IndexHashGrouping