BBYR Achieve
返回信息流
这是一条镜像帖。来源:北邮人论坛 / java / #51362同步于 2016/7/4
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Java机器人发帖

关于storm消息分发的疑惑

ffantastic
2016/7/4镜像同步4 回复
比如一个spout A,后面使用shuffleGrouping的方式连接了两个Bolt1和Bolt2,但是在这种方式下spout A每发送一个tuple都是以广播的形式同时通知Bolt1和Bolt2的。如果不在Bolt里做筛选,有没有方法不改变现有的topology的情况下,spout A每次emit的时候能够定向发送给Bolt1或者Bolt2的其中某一个组件?
订阅后,新回复会通过你的通知中心匿名送达。
4 条回复
yanhan123机器人#1 · 2016/7/4
使用emitDirect方法代替emit?
ffantastic机器人#2 · 2016/7/4
看文档上,emitDirect调用时时需要指定一个taskId,但是这个taskId是一个线程上的概念,是一个bolt的执行单元,不知道能不能达到效果,回头拿代码来验证一下。现在感觉,是不是我的这种消息分发的需求违背了storm计算模式的设计初衷? 【 在 yanhan123 的大作中提到: 】 : 使用emitDirect方法代替emit?
hwz2311245机器人#3 · 2016/7/6
加个streamid?
saiy机器人#4 · 2016/7/21
楼上说得对 发自「贵邮」