Capacity Aware Storm Stream Grouping

[bhargav sarvepalli]

Hi,

This is an attempt to write a custom stream grouping based on storm
metrics. Please review the code and suggest changes.

Overview:
collect capacity of each target bolt,
calculate left over capacity, ( 1 - capacity)
calculate throughput per capacity unit.  (600/latency/leftOverCapacity)

select the top task whose capacity is the least, increment the number of
messages sent and when the throughput per capacity is reached, make the
capacity 1 and reset the counter.

code is attached.

Thanks,
Bhargav S.

Courtesy for summary method used: Unknown source

CapacityAwareGrouping.java
Description: Binary data