You can also connect directly to Nimbus through its Thrift service.
(http://www.andys-sundaypink.com/i/retrieve-storm-cluster-statistic-from-nimbus-java-mode/
)

However I found it much easier to just use the REST API of the UI that Yury
mentioned, which will serve your purposes just fine.

On Wed, Feb 11, 2015 at 12:43 AM, Vincent Russell <[email protected]
> wrote:

> Ok thanks. So I should be able to use a nimbus client to give me what I
> want.
> On Feb 10, 2015 5:53 AM, "Yury Ruchin" <[email protected]> wrote:
>
>> In Storm 0.9, there is REST API which you can use to query component- and
>> topology-level stats, including acked/transferred. Please refer to:
>> https://github.com/apache/storm/blob/master/STORM-UI-REST-API.md
>>
>> 2015-02-10 10:47 GMT+03:00 Vincent Russell <[email protected]>:
>>
>>> Sure.  How can I get that programmatically?
>>> On Feb 10, 2015 2:13 AM, "Kosala Dissanayake" <[email protected]>
>>> wrote:
>>>
>>>> Wouldn't that just be (transferred - acked)?
>>>>
>>>> On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <
>>>> [email protected]> wrote:
>>>>
>>>>>
>>>>> Is there a way with storm to get a value for the current number of
>>>>> tuples that haven't been acked yet?
>>>>>
>>>>>
>>>>> Thanks,
>>>>>
>>>>
>>>>
>>

Reply via email to