Storm流分组介绍

Storm流分组介绍
        8、自定义分组
            自定义分组（Custome Grouping），通过实现CustomStreamGrouping接口可以实现自定义的流分组，接口定义如下：
            public interface CustomStreamGrouping extends Serializable {
                void prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks);
                List<Integer> chooseTasks(int taskId, List<Object> values);
            }