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

Packages that use LoadAwareCustomStreamGrouping

Package	Description
org.apache.storm.daemon
org.apache.storm.executor
org.apache.storm.grouping

Uses of LoadAwareCustomStreamGrouping in org.apache.storm.daemon

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

Modifier and Type	Class	Description
static class	GrouperFactory.BasicLoadAwareCustomStreamGrouping	A bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping.

Fields in org.apache.storm.daemon declared as LoadAwareCustomStreamGrouping

Modifier and Type	Field	Description
static final LoadAwareCustomStreamGrouping	GrouperFactory.DIRECT

Methods in org.apache.storm.daemon that return LoadAwareCustomStreamGrouping

Modifier and Type	Method	Description
static LoadAwareCustomStreamGrouping	GrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String,Object> topoConf)

Uses of LoadAwareCustomStreamGrouping in org.apache.storm.executor

Fields in org.apache.storm.executor with type parameters of type LoadAwareCustomStreamGrouping

Modifier and Type	Field	Description
protected final List<LoadAwareCustomStreamGrouping>	Executor.groupers
protected final Map<String,Map<String,LoadAwareCustomStreamGrouping>>	Executor.streamToComponentToGrouper

Methods in org.apache.storm.executor that return types with arguments of type LoadAwareCustomStreamGrouping

Modifier and Type	Method	Description
Map<String,Map<String,LoadAwareCustomStreamGrouping>>	Executor.getStreamToComponentToGrouper()

Uses of LoadAwareCustomStreamGrouping in org.apache.storm.grouping

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

Modifier and Type	Class	Description
class	LoadAwareShuffleGrouping