Wie könnte der Sturmbolzen mehrere Tupel von verschiedenen Ausgüssen oder anderen Bolzen aufnehmen?

Question

Ich habe zwei serialisierbare Klasse A und B. Und es gibt zwei Arten von Auslauf A_spout und B_spout.Jeder Auslauf Auslauf Parallelitätsklasse zu Bolzen C.Aber es gibt keinen Unterschied über Tupel in Methode ausführen, so wie könnte ich sie unterscheiden?

Answer 1

Jeder Eingang Tuple in Bolt.execute() trägt einige Meta-Daten, die auch den Eingangsoperator enthält er herkommt:

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