【文件属性】:
文件名称:grouping策略-storm实时处理
文件大小:1.42MB
文件格式:PPT
更新时间:2021-04-26 10:31:02
大数据 storm
grouping策略
shuffleGrouping(随机分组)随机分发tuple到Bolt的任务,保证每个任务获得相等数量的tuple。
fieldsGrouping(按照字段分组,在这里即是同一个单词只能发送给一个Bolt)
allGrouping(广播发送,即每一个Tuple,每一个Bolt都会收到)
globalGrouping(全局分组,将Tuple分配到task id值最低的task里面)
noneGrouping(随机分派)目前,无分组等效于随机分组。
directGrouping(直接分组,指定Tuple与Bolt的对应发送关系)
customGrouping (自定义的Grouping)