org.apache.storm.grouping

Interface LoadAwareCustomStreamGrouping

All Superinterfaces:

CustomStreamGrouping, Serializable

All Known Implementing Classes:

LoadAwareShuffleGrouping

public interface LoadAwareCustomStreamGrouping
extends CustomStreamGrouping

Method Summary

Modifier and Type	Method and Description
List<Integer>	chooseTasks(int taskId, List<Object> values, LoadMapping load)

Methods inherited from interface org.apache.storm.grouping.CustomStreamGrouping

chooseTasks, prepare

Method Detail

chooseTasks

List<Integer> chooseTasks(int taskId,
                          List<Object> values,
                          LoadMapping load)