storm的bolt流向多个bolt问题,新手求带路,感谢

依天丶 发布于 2016/09/01 16:56
阅读 2K+
收藏 0

现在想把数据发送到一个作为中转的bolt1

在bolt1中做一些处理后传不同的数据到bolt2和bolt3

看了github上一个例子,但是还是不理解是怎样准确的将数据分发对应的bolt里,emit函数的第一个参数,new values里的两个参数 分别代表什么意思  topology里filedgrouping应该是这些里哪一个参数?

求指教   

 collector.emit("trade_stream", new Values(tupleId, trade));      
 collector.emit("customer_stream",new Values(tupleId, customer));

declarer.declareStream("trade_stream", new Fields("ID", "TRADE"));
declarer.declareStream("customer_stream",new Fields("ID","CUSTOMER"));



加载中
1
e
edouardzyc

https://github.com/alibaba/jstorm/blob/49d834764d3c638dac3a939c800aed23484a41e8/docs/jstorm-doc/backup/advance_cn/split_merge_cn.md

里面已经说的挺详细了

返回顶部
顶部