Hi, Maybe you can override spout ack/fail method ant take it from there . In case you use ackers Vladi
On Fri, Nov 14, 2014 at 4:35 PM, Vadim Smirnov <v2smir...@mail.ru> wrote: > Unfortunate, it is all about as create metrics and read it outside. I am > want read metric value from Spout code. > > > Fri, 14 Nov 2014 08:43:57 -0500 от Otis Gospodnetic < > otis.gospodne...@gmail.com>: > > Hi Vadim, > > Check a list of Storm metrics listed in > http://blog.sematext.com/2014/01/30/announcement-apache-storm-monitoring-in-spm/ > -- I think some of them may be what you are after, though presented as > rates/throughput vs. a single total number. Alternatively, have a look at > http://www.endgame.com/blog/storm-metrics-how-to.html . > > Otis > -- > Monitoring * Alerting * Anomaly Detection * Centralized Log Management > Solr & Elasticsearch Support * http://sematext.com/ > > > On Fri, Nov 14, 2014 at 8:00 AM, Vadim Smirnov <v2smir...@mail.ru > <https://e.mail.ru/compose/?mailto=mailto%3av2smir...@mail.ru>> wrote: > > I am have several input Spout and several output Bolts. I am want know how > many tuples already processed. For it i am create metric an .incr() it on > output Bolt .execute(). How i am can read metric value from Spout code ? > > > >
