Hello,

I'm trying to find out how to write topology in YAML that Flux proceses and which has multiple output streams (not just default).
I'm using python, so they are FluxShellSpouts.

Here is a brief scheme:

|[first_spout] [second_spout] \__________ __________/ | [process_bolt] __________|__________ / \ [unit_bolt] [incident_bolt] \__________ __________/ | [save_bolt]|


There is StreamID parameter in stream part of yaml, but there is no mention about it in output fileds: http://storm.apache.org/releases/1.0.1/flux.html -> Streams and Stream Groupings

Can someone please state simple example with multiple output streams?

Thank you.


Reply via email to