storm数据流分组

数据流分组定义了一个数据流中的tuple如何分发给topology中不一样bolt的task。 Shuffle grouping(随机分组):这种方式会随机分发 tuple 给 bolt 的各个 task,每一个bolt 实例接收到的相同数量的 tuple。 Fields grouping(按字段分组):根据指定字段的值进行分组。好比说,一个数据流根据“word”字段进行分组,全部具备相同“word
相关文章
相关标签/搜索