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

Reply via email to