2014-09-11 127 views
2

我是新来的风暴环境,我有一个问题!我有2个喷嘴(spoutA和spoutB)将数据发送到螺栓(螺栓1)。我定义这个螺栓这样:如何获取螺栓数据源?

builder.setBolt("bolt1", bolt1).shuffleGrouping("spoutA").shuffleGrouping("spoutB"); 

是否有bolt1办法知道收到的每条记录的是其源(spoutA或spoutB)?

回答

1
official doc page

如果实现订阅了多个输入源的螺栓,你可以找到元组来自哪个组件使用元组#getSourceComponent方法