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
