Storm的spout中如何将tuple发给指定的Blot？

比如下图，我想将Spout中的某些tuple发给Blot A，某些tuple发给Blot C。怎么指定呢？多谢

1 个解决方案

#1

这个太简答了，在Spout中通过SpoutOutputCollector collector来进行发送，collector.emit方法 里就提供了针对不同的方向进行发送。emit(java.lang.String streamId, java.util.List<java.lang.Object> tuple)