org.apache.storm.metric.internal

Class MultiLatencyStat<T>

java.lang.Object

org.apache.storm.metric.internal.MultiLatencyStat<T>

public class MultiLatencyStat<T>
extends Object

Keeps track of approximate latency for the last 10 mins, 3 hours, 1 day, and all time. for the same keys

Constructor Summary

Constructors

Constructor and Description
MultiLatencyStat(int numBuckets) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
Map<String,Map<T,Double>>	getTimeLatAvg()
void	record(T key, long latency) Record a latency value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiLatencyStat

public MultiLatencyStat(int numBuckets)

Constructor.

Parameters:

numBuckets - the number of buckets to divide the time periods into.

Method Detail

record

public void record(T key,
                   long latency)

Record a latency value.

Parameters:

latency - the measurement to record

getTimeLatAvg

public Map<String,Map<T,Double>> getTimeLatAvg()

close

public void close()