Hello,
I recently started working with Storm and I want to understand better the
way tuples are routed in a topology. Let us assume the following topology
with Spout A and Bolts B and C:
Spout-A---------->Bolt-B
+-----------> Bolt-C
Meaning that Spout A produces tuples for both bolts. In my use-case I want
to control the tuples I am emitting to each bolt. In more detail, every
time nextTuple() of Spout A is called, I want to control where the new
tuple is going (and not be emitted in both bolts). Correct me if I am
wrong, but I believe that I need to use direct grouping to achieve the
aforementioned functionality. Am I in the right path about using direct
grouping or should I follow a different approach?
In addition, I was looking at Storm's documentation about Direct Grouping,
but the link does not work (
https://storm.incubator.apache.org/documentation/Direct-groupings.html).
Where can I find more information about direct grouping?
--
Nikolaos Romanos Katsipoulakis,
University of Pittsburgh, PhD candidate,
email: [email protected]
