Dear All,
I am trying to use the LoadAwareShuffler which is currently still
underdevelopment as i understand. I was able to download the code and build
it, the LoadAwareShuffler works but I am a little bit hindered from using
it; the reason for that is the way a bolt is declared in Storm topology.
To declare a bolt I write something like that:
builder.setBolt("boltName", new myClass(), 5)
here I have 5 instances of myClass() for this bolt, the thing is I want 1
of these 5 instances to have a modifiedMyClass() implementation that is a
little bit faster than the ordinary myClass() implementation.
So, the final bolt configuration would be 4 slow instances and 1 fast
instance, but all of them are part of "boltName" and that's how the
LoadAwareShuffler can be utilized best.
So how can I achieve such behavior in Topology declaration ?
Thanks all
Hazem
