Hello!
I have a use case where I need that two bolts should be colocated either
on the same worker JVM or in the same node.
We would like to know about this feature for the following reasons:
1. Computing the time that took for a tuple to be processed by the whole
topology
Suppose that you have the topology:
Spout->B1->B2->BoltMeasureTime
(where BoltMeasure time is the bolt where we would like to compute the
total time spent by the tuple in the topology),
we would like that BoltMeasureTime to be placed on the same JVM as the
Spout or on the same node.
2. Suppose that you have a Spout that is consuming data from a Database.
For performance reasons perhaps you would like to place the Spout nearby
the Database.
I know that Nimbus is responsible to spread the tasks among the workers
based on round robin algorithm but I'm wondering if there is a different
way to specify where the tasks to be executed.
I look forward for your suggestions/comments.
Best regards,
Florin
