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 >
