您当前的位置: 首页 > 

宝哥大数据

暂无认证

  • 0浏览

    0关注

    1029博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

Strom学习00---Grouping

宝哥大数据 发布时间:2017-03-12 23:10:37 ,浏览量:0

storm分组策略

(1)ShuffleGrouping:随机分组,**随机分发**Stream中的tuple,保证每个Bolt的Task接收Tuple数量大致一致; (2)FieldsGrouping:按照字段分组,保证相同字段的Tuple分配到同一个Task中; (3)AllGrouping:广播发送,每一个Task都会受到所有的Tuple; (4)GlobalGrouping:全局分组,所有的Tuple都发送到同一个Task中,此时一般将当前Component的并发数目设置为1; (5)NonGrouping:不分组,和ShuffleGrouping类似,当前Task的执行会和它的被订阅者在同一个线程中执行; (6)DirectGrouping:直接分组,直接指定由某个Task来执行Tuple的处理,而且,此时必须有emitDirect方法来发送; (7) localOrShuffleGrouping:和ShuffleGrouping类似,若Bolt有多个Task在同一个进程中,Tuple会随机发给这些Task。

关注
打赏
1587549273
查看更多评论
立即登录/注册

微信扫码登录

0.0397s