You would need to design a custom scheduler: http://xumingming.sinaapp.com/885/twitter-storm-how-to-develop-a-pluggable-scheduler/
On Wed, Aug 6, 2014 at 5:08 AM, Spico Florin <[email protected]> wrote: > 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 > > >
