我有两个喷口
喷口-1:持续发出tweets
喷口2:每30秒发射一个新的随机数。
目标:我正在尝试过滤tweets的基础上从喷口二随机。
我创建了一个从两个喷口获取数据的螺栓
builder.setBolt("process", new ProcessBolt())
.shuffleGrouping("spout1")
.shuffleGrouping("spout2");
但“过程”螺栓似乎只能从spout2获取数据。随机数喷口。
实现这一目标的最佳方法是什么?拓扑应该不同。
p、 s:随机数发生器必须是独立的喷口。
暂无答案!
目前还没有任何答案,快来回答吧!