Package org.xbib.metrics.common

Class ExponentiallyDecayingReservoir

java.lang.Object

org.xbib.metrics.common.ExponentiallyDecayingReservoir

All Implemented Interfaces:

org.xbib.metrics.api.Reservoir

public class ExponentiallyDecayingReservoir
extends java.lang.Object
implements org.xbib.metrics.api.Reservoir

An exponentially-decaying random reservoir of longs. Uses Cormode et al's forward-decaying priority reservoir sampling method to produce a statistically representative sampling reservoir, exponentially biased towards newer entries.

See Also:

Cormode et al. Forward Decay: A Practical Time Decay Model for Streaming Systems. ICDE '09: Proceedings of the 2009 IEEE International Conference on Data Engineering (2009)

Constructor Summary

Constructors

Constructor	Description
ExponentiallyDecayingReservoir()	Creates a new ExponentiallyDecayingReservoir of 1028 elements, which offers a 99.9% confidence level with a 5% margin of error assuming a normal distribution, and an alpha factor of 0.015, which heavily biases the reservoir to the past 5 minutes of measurements.
ExponentiallyDecayingReservoir(int size, double alpha)	Creates a new ExponentiallyDecayingReservoir.
ExponentiallyDecayingReservoir(int size, double alpha, org.xbib.metrics.api.Clock clock)	Creates a new ExponentiallyDecayingReservoir.

Method Summary

Modifier and Type	Method	Description
org.xbib.metrics.api.Snapshot	getSnapshot()
int	size()
void	update(long value)
void	update(long value, long timestamp)	Adds an old value with a fixed timestamp to the reservoir.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExponentiallyDecayingReservoir

public ExponentiallyDecayingReservoir()

Creates a new ExponentiallyDecayingReservoir of 1028 elements, which offers a 99.9% confidence level with a 5% margin of error assuming a normal distribution, and an alpha factor of 0.015, which heavily biases the reservoir to the past 5 minutes of measurements.

ExponentiallyDecayingReservoir

public ExponentiallyDecayingReservoir(int size,
                                      double alpha)

Creates a new ExponentiallyDecayingReservoir.

Parameters:

size - the number of samples to keep in the sampling reservoir

alpha - the exponential decay factor; the higher this is, the more biased the reservoir will be towards newer values

ExponentiallyDecayingReservoir

public ExponentiallyDecayingReservoir(int size,
                                      double alpha,
                                      org.xbib.metrics.api.Clock clock)

Creates a new ExponentiallyDecayingReservoir.

Parameters:

size - the number of samples to keep in the sampling reservoir

alpha - the exponential decay factor; the higher this is, the more biased the reservoir will be towards newer values

clock - the clock used to timestamp samples and track rescaling

Method Detail

size

public int size()

Specified by:

size in interface org.xbib.metrics.api.Reservoir

update

public void update(long value)

Specified by:

update in interface org.xbib.metrics.api.Reservoir

update

public void update(long value,
                   long timestamp)

Adds an old value with a fixed timestamp to the reservoir.

Parameters:

value - the value to be added

timestamp - the epoch timestamp of value in seconds

getSnapshot

public org.xbib.metrics.api.Snapshot getSnapshot()

Specified by:

getSnapshot in interface org.xbib.metrics.api.Reservoir