Hi,
I've seen the explanations
<http://www.michael-noll.com/blog/2012/10/16/understanding-the-parallelism-of-a-storm-topology/>,
but none of them explain it in terms of what I see in the code. This is
what I understood:
int BoltParallelism = 3;
int BoltTaskParallelism = 2;
builder.setBolt("bolt1", new BoltA(), *BoltParallelism*)
.setNumTasks(*BoltTaskParallelism*)
BoltParallelism creates 3 instances of BoltA. These are the executors.
BoltTaskParallelism allows Tuples to come into BoltA very fast, and the
Bolt creates a task for processing each incoming Tuple. If there are not
enough tasks, then the excess Tuples are made to wait in a queue of the
executor.
Strange thing is that the explanation says the tasks are run in a single
thread, so obviously I misunderstood something. Could you help me
understand it?
--
Regards,
Navin
