Hi Jens, Thanks for your replying and good idea. I will try to count at spouts(in ack or fail block) :)
Regards, Tetsuya On Tue, Jan 13, 2015 at 9:13 PM, Jens-U. Mozdzen <[email protected]> wrote: > Hi Tetsuya, > > Zitat von Tetsuya MATSUDA <[email protected]>: > > I agree the values are multiples of 20 and they're not row count. >> So if possible, I want to get raw count of them. >> >> Now, I have only one idea. >> I count all parameters myself like below, >> -------------------- >> begin >> handling tuple >> dbclient.incr("ack_count") >> ack(tup) >> rescue => err >> dbclient.incr("fail_count") >> log.error(tup.id.to_s + ":" + err.to_s) >> fail(tup) >> end >> -------------------- >> >> Do you have other better ideas? >> > > how about adding the counters to your spouts? These do the emits and are > notified of acks and fails, so you can do the count "at the source" and > per-stream. > > Regards, > Jens > > -- 松田 徹也 -Tetsuya MATSUDA- E-mail : [email protected] <[email protected]>
