我有两个可序列化的类a和b，有两种类型的喷口a\u喷口和b\u喷口。每个喷口都向bolt c发出并行类。但是方法execute中的元组没有区别，所以我如何区分它们？
0s7z1bwu1#
每个输入 Tuple 在 Bolt.execute() 携带一些元数据，这些元数据还包含其来源的输入运算符：
Tuple
Bolt.execute()
public void execute(Tuple input) { if(input.getSourceComponent().equals("A_Spout")) { // do something } else { // data from B_Spout; do something different } }
1条答案
按热度按时间0s7z1bwu1#
每个输入
Tuple在Bolt.execute()携带一些元数据，这些元数据还包含其来源的输入运算符：