Fair enough I missed the last sentence. But it could be misconstrued since he didn't mention groupings at all in his original email. On Oct 30, 2014 7:59 AM, "Andrew Xor" <[email protected]> wrote:
> 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 >>>> >>> >>> >
