Hi all,
I am working on a project to build an order processing pipeline on top of
Storm. In order to measure performance, for every spout/bolt and every
order processed by them, one requirement is to generate custom metrics in
the form order id, order entry timestamp in milisec, order exit timestamp
in milisec and then use a metrics consumer to collect and further process
those metrics. I will greatly appreciate it if any one can share some ideas
as to how to implement this requirement. My question is, getValueAndReset
in IMetrics interface is a callback method. Looks to me that in order
to collect the metrics using IMetrics interface, I will have to use a
memory queue to temporarily store metrics generated when orders are
processed in any spout and bolt and wait for getValueAndReset to be called.
Any better idea?
Thanks,
James
