Hi Jens, I'm not entirely sure if I understand what you want to achieve, but wouldn't having two input streams to bolt C, one each from A and B, each with a fields grouping, solve your problem?
Cheers, Kosala On Mon, Jan 5, 2015 at 9:30 PM, Jens-U. Mozdzen <[email protected]> wrote: > Hi *, > > I have a bolt C (running with multiple instances) which receives two input > streams, from bolt A and B. > > Both input streams have the same key fields in their tuples, plus > additional, distinct fields. > > Does Storm support fieldsGrouping() so that tuples from both bolt A and B > are distributed across the bolt C instances, in a way that tuples with > identical key fields from A and B end up on the same instance of C? IOW, > can fieldsGrouping() do its grouping from a receiving end's point of view, > rather than from the sender's POV? > > Regards, > Jens > > >
