[SAMZA-349] add timer in metrics

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.8.0
• Assignee: Yan Fang
• Reporter: Yan Fang
• Created: 20/Jul/14 07:00
• Updated: 17/Nov/14 23:46
• Resolved: 05/Aug/14 06:49

Description

If my understanding is correct, the metrics we provide are for every 60 seconds and all counters will be reset every 60 seconds. Current the MetricsSnapshotReporter seems missing this implementation. It sends out the metrics every 60 seconds but does not reset the counter value.

 registry.getGroup(group).foreach {
          case (name, metric) =>
            metric.visit(new MetricsVisitor {
              def counter(counter: Counter) = groupMsg.put(name, counter.getCount: java.lang.Long)
              def gauge[T](gauge: Gauge[T]) = groupMsg.put(name, gauge.getValue.asInstanceOf[Object])
            })
        }

Issue Links

• blocks: SAMZA-251 Add metrics for choose/process/window/commit/send time
• is related to: SAMZA-467 Add latency metrics to the different KeyValueStore layers in Samza
• is related to: SAMZA-401 Add utilization metrics for the event loop
• relates to: SAMZA-421 Test the performance before and after adding the Timer metric