Storm拓扑之Stream Grouping

Stream的分组策略 Stream Grouping – 定义了一个流在Bolt任务间该如何被切分,谁来处理哪些数据流,按照什么规则来分配. 随机分组 Shuffle Grouping- 随机分组, 随机派发stream里面的tuple,保证每个bolt接收到的tuple数目大致相同。 字段分组 Fields grouping – 根据指定字段的值进行分组。比如说,一个数据流根据’word’字段进行分组,所有具有相同的’w... ... [查看更多]

Views: 255