apachestorm,tweet处理拓扑

bfnvny8b  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(194)

我有两个喷口
喷口-1:持续发出tweets
喷口2:每30秒发射一个新的随机数。
目标:我正在尝试过滤tweets的基础上从喷口二随机。
我创建了一个从两个喷口获取数据的螺栓

builder.setBolt("process", new ProcessBolt())
        .shuffleGrouping("spout1")
        .shuffleGrouping("spout2");

但“过程”螺栓似乎只能从spout2获取数据。随机数喷口。
实现这一目标的最佳方法是什么?拓扑应该不同。
p、 s:随机数发生器必须是独立的喷口。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题