Well, in essence what I said is that if some Bolts are subscribed to a stream they will receive all tuples that flow in that stream regardless of the shuffling you have in each Bolt.
Kindly yours, Andrew Grammenos -- PGP PKey -- <https://www.dropbox.com/s/2kcxe59zsi9nrdt/pgpsig.txt> https://www.dropbox.com/s/ei2nqsen641daei/pgpsig.txt On Thu, Oct 30, 2014 at 1:54 PM, Nathan Leung <[email protected]> wrote: > Andrews response is misleading. You can use streams as described by > another user in your other thread. When you create your topology bolt b > subscribed to bolt a stream 1, etc. Then when bolt a emits it can specify > the stream id to emit to, and the tuple will be sent on the appropriate > stream to the appropriate bolt. > On Oct 30, 2014 7:19 AM, "Andrew Xor" <[email protected]> wrote: > >> Hi, >> >> First of all you have to understand the limitations of Storm Processor; >> by design it emits *all* tuples to *all* subscribed bolts. This means that >> if you have Bolts A,B,C subscribed to a Bolt/Spout D tuples emitted by the >> said storm primitive will go to all subscribed Bolts. In effect the >> grouping type is *not* a routing scheme but a parallelism scheme for >> distributing the tuples received in the bolt to its workers. To achieve the >> said functionality you have to get creative; for example you could >> subscribe these bolts using three distinct direct streams, one for each and >> then conditionally emit to each stream the tuples you want to be processed >> by each Bolt. >> >> Hope this helped. >> >> Kindly yours, >> >> Andrew Grammenos >> >> -- PGP PKey -- >> <https://www.dropbox.com/s/2kcxe59zsi9nrdt/pgpsig.txt> >> https://www.dropbox.com/s/ei2nqsen641daei/pgpsig.txt >> >> On Thu, Oct 30, 2014 at 12:57 PM, clay teahouse <[email protected]> >> wrote: >> >>> Hello All, >>> Can someone share an example of a bolt with multi stream output, with >>> each particular output stream going to a particular bolt? >>> >>> Bolt A =>stream 1 => Bolt B >>> Bolt A => stream 2 => Bolt C >>> Bolt A => stream 3 => Bolt D >>> >>> thanks, >>> Clay >>> >> >>
