Hi all,
I'm new to Storm.
I'm finding the way to count latency per tuple.
What I exactly want are:
(1) Mean latency of all tuples elapsed between a Spout generates them
and last Bolt processes them
(2) Maximum latency of all tuples elapsed between a Spout generates
them and last Bolt processes them
Example:
If topology is
Spout => Bolt0 => Bolt1
and tupleA is generated on 12:00:00 at Spout and finished on 12:00:05
at Bolt1, the latency of tupleA is 5 seconds.
Especially, I want to calculate latencies of WourdCountTopology in
storm-starter.
Any advice?
Thanks,
Nakatani
|