分享

这样的topology在代码中应该怎么写啊

mjjian0 发表于 2015-4-14 23:10:52 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 2 11598
比如说我的数据是这样的name     age      sex
a             23        男
b             22        女
c            22         男

d            22        女


我想在spout发射的时候把性别为男的发到一个bolt1,为女的发到另一个bolt2,然后两个bolt都最后发到bolt3去。


已有(2)人评论

跳转到指定楼层
langke93 发表于 2015-4-14 23:46:50
使用stream grouping,按照sex分组,如下图男的发到一个boltA ,女的发到BoltB




也就是会使用stream grouping即可
相关内容参考:

Storm入门教程2:Storm术语介绍及 构建Topology

storm 入门原理介绍

mac10.9下eclipse的storm入门及开发环境搭建












回复

使用道具 举报

mjjian0 发表于 2015-4-19 18:41:34
langke93 发表于 2015-4-14 23:46
使用stream grouping,按照sex分组,如下图男的发到一个boltA ,女的发到BoltB

我知道有6种分组方式,但是就是不知道对于这个情况怎么用。所以才问的
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条