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
- fieldsGrouping() for multiple input streams Jens-U. Mozdzen
-