MultiLatencyStat (Storm 2.6.1 API)

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

Description

MultiLatencyStat(int numBuckets)

Constructor.
Method Summary

Modifier and Type

Method

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 Details
- MultiLatencyStat
  
  public MultiLatencyStat(int numBuckets)
  
  Constructor.
  
  Parameters:
  
  numBuckets - the number of buckets to divide the time periods into.
Method Details
- 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()