Problems calculating capacity for storm bolt.

[Jon Bonazza <jb...@gaikai.com>]

So If I understand correctly,  the formula for calculating capacity for an
executor for the last 10 min is:

capacity = (num_executed * avg_executed_ms)  / 600000

and the capacity of a bolt is simply the max capacity of all of the bolt's
executors.

I am trying to calculate this using the thrift api, but it is posing to be
a larger challenge than I anticipated, given the design of the api.

>From each ExecutorSummary, I can get both a map of stream ids to the
executed count for the last 10m and a map of stream ids to avg executed ms
(latency) for the last 10m . I am assuming that each stream id in the first
map also exists in the second map. Is this the case?

In the end, I am trying to get each component of the forumla introduced at
the beginning of this message. do I just take the max of all the values in
each map? The Avg? What?

Thanks in advance!