java - Storm bolt 如何从不同的喷口或其他 bolt 接收多种类型的元组？

Question

我有两个可序列化的类A和B。并且有两种spout A_spout和B_spout。每个spout向bolt C发出并行类。但是方法execute中的元组没有区别，所以我如何区分它们？

Answer 1

每个输入Tuple在Bolt.execute()携带一些元数据，其中还包含它源自的输入运算符:

public void execute(Tuple input) {
    if(input.getSourceComponent().equals("A_Spout")) {
        // do something
    } else {
        // data from B_Spout; do something different
    }
}