Hi, if you're using the Trident APIs something like this should be enough:
stream.each( new Fields(), new Timestamper(), new Fields("timestamp")),
where TimeStamper is derived from BaseFunction where you do something
like collector.emit(new
Values(new Date()) in the executor(tuple, collector) method.
2017-07-20 22:19 GMT+02:00 preethini v <[email protected]>:
> Hi,
>
> Is there a way to measure the latency of storm system apart from the
> parameter "complete latency" from Storm UI?
>
> I cannot enable the acking, hence complete latency is always 0. I am
> looking for other ways to measure end to end latency.
>
> Can we attach a timestamp when a tuple is emitted and check its end time
> in execute() method of my last bolt? I am trying to do this, but I do not
> see a way to attach timestamp to the tuple and send it further downstream.
>
> Any hints to measure the latency would be very helpful. Thanks.
>
> Best,
> Preethini
>
--
Federico D'Ambrosio
