LatencyStat (Storm 2.6.1 API)

java.lang.Object

org.apache.storm.metric.internal.LatencyStat

public class LatencyStat extends Object

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

Constructor Summary

Constructors

Constructor

Description

LatencyStat(int numBuckets)

Constructor.
Method Summary

Modifier and Type

Method

Description

void

close()

Map<String,Double>

getTimeLatAvg()

Get time latency average.

void

record(long latency)

Record a specific latency.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- LatencyStat
  
  public LatencyStat(int numBuckets)
  
  Constructor.
  
  Parameters:
  
  numBuckets - the number of buckets to divide the time periods into.
Method Details
- record
  
  public void record(long latency)
  
  Record a specific latency.
  
  Parameters:
  
  latency - what we are recording
- getTimeLatAvg
  
  public Map<String,Double> getTimeLatAvg()
  
  Get time latency average.
  
  Returns:
  
  a map of time window to average latency. Keys are "600" for last 10 mins "10800" for the last 3 hours "86400" for the last day ":all-time" for all time
- close
  
  public void close()