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 classGrouperFactory.BasicLoadAwareCustomStreamGroupingA bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping.Fields in org.apache.storm.daemon declared as LoadAwareCustomStreamGrouping Modifier and Type Field Description static LoadAwareCustomStreamGroupingGrouperFactory. DIRECTMethods in org.apache.storm.daemon that return LoadAwareCustomStreamGrouping Modifier and Type Method Description static LoadAwareCustomStreamGroupingGrouperFactory. 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 List<LoadAwareCustomStreamGrouping>Executor. groupersprotected Map<String,Map<String,LoadAwareCustomStreamGrouping>>Executor. streamToComponentToGrouperMethods 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 classLoadAwareShuffleGrouping
-