grouping策略-storm实时处理

时间:2021-04-26 10:31:02
【文件属性】:
文件名称: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)

网友评论