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


Reply via email to