org.apache.storm.utils

Class DisruptorQueue.QueueMetrics

java.lang.Object

org.apache.storm.utils.DisruptorQueue.QueueMetrics

Enclosing class:

DisruptorQueue

public class DisruptorQueue.QueueMetrics
extends Object

This inner class provides methods to access the metrics of the disruptor queue.

Constructor Summary

Constructors

Constructor and Description
QueueMetrics()

Method Summary

Modifier and Type	Method and Description
double	arrivalRate()
long	capacity()
void	close()
Object	getState()
void	notifyArrivals(long counts)
void	notifyDepartures(long counts)
long	overflow()
float	pctFull()
long	population()
long	readPos()
double	sojournTime()
long	writePos()

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueMetrics

public QueueMetrics()

Method Detail

writePos

public long writePos()

readPos

public long readPos()

overflow

public long overflow()

population

public long population()

capacity

public long capacity()

pctFull

public float pctFull()

arrivalRate

public double arrivalRate()

sojournTime

public double sojournTime()

getState

public Object getState()

notifyArrivals

public void notifyArrivals(long counts)

notifyDepartures

public void notifyDepartures(long counts)

close

public void close()