-
storm实时处理采用的分组策略
资源介绍
grouping策略
shuffleGrouping（随机分组）随机分发tuple到Bolt的任务，保证每个任务获得相等数量的tuple。
fieldsGrouping（按照字段分组，在这里即是同一个单词只能发送给一个Bolt）
allGrouping（广播发送，即每一个Tuple，每一个Bolt都会收到）
globalGrouping（全局分组，将Tuple分配到task id值最低的task里面）
noneGrouping（随机分派）目前，无分组等效于随机分组。
directGrouping（直接分组，指定Tuple与Bolt的对应发送关系）
customGrouping （自定义的Grouping）
- 上一篇: Kafka面试题.pdf
- 下一篇: 基于python开发的进出口企业查询软件v2.1.1下载