FluxShellSpout extends ShelllSpout so it can use streams with ShellSpout's stream mechanism. You just define which stream to use in the streams section and set the stream in your ShellMsg.
https://github.com/apache/storm/blob/1.0.x-branch/storm-core/src/jvm/org/apache/storm/spout/ShellSpout.java On May 17, 2016 4:48 AM, "Joe Darkless" <[email protected]> wrote: > 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. > > >
