如何进行Twitter Storm Stream Grouping编写自定义分组实现

本篇文章为大家展示了如何进行Twitter Storm Stream Grouping编写自定义分组实现，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

##自定义Grouping测试

Storm是支持自定义分组的，本篇文章就是探究Storm如何编写一个自定义分组器，以及对Storm分组器如何分组数据的理解。

这是我写的一个自定义分组，总是把数据分到第一个Task：

public class MyFirstStreamGrouping implements CustomStreamGrouping {    private static Logger log = LoggerFactory.getLogger(MyFirstStreamGrouping.class);    private List tasks;    @Override    public void prepare(WorkerTopologyContext context, GlobalStreamId stream,                List targetTasks) {            this.tasks = targetTasks;            log.info(tasks.toString());    }           @Override    public List chooseTasks(int taskId, List