org.streaminer.stream.quantile.rss

Class RSSQuantiles

java.lang.Object

org.streaminer.stream.quantile.rss.RSSQuantiles

All Implemented Interfaces:

Serializable, IQuantiles<Double>

public class RSSQuantiles
extends Object
implements IQuantiles<Double>, Serializable

A stream version of the rss technique presented by Anna Gilbert, Yannis Kotidis, S. Muthukrishanan, and Matrin Strauss in the paper "How to summarize the Universe".

Author:

Carsten Przyluczky

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	CANT_ESTIMATE
static int	ELEMENTS_PER_BUCKET

Constructor Summary

Constructors

Constructor and Description
RSSQuantiles(float epsilon, float delta, int maxValue) The constructor invokes all data-structure creation

Method Summary

Methods

Modifier and Type	Method and Description
int	getElementsPerBucket()
int	getMaxBucketCount()
Double	getQuantile(double q)
void	offer(Double value)
void	setElementsPerBucket(int newCount)
void	setMaxBucketCount(int newCount)

Methods inherited from class java.lang.Object

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

Field Detail

CANT_ESTIMATE

public static final int CANT_ESTIMATE

See Also:

Constant Field Values

ELEMENTS_PER_BUCKET

public static int ELEMENTS_PER_BUCKET

Constructor Detail

RSSQuantiles

public RSSQuantiles(float epsilon,
            float delta,
            int maxValue)

The constructor invokes all data-structure creation

Parameters:

epsilon - precision

delta - error-probability

maxValue - the maximum value the will be handled by this algorithm (|U|)

Method Detail

offer

public void offer(Double value)

Specified by:

offer in interface IQuantiles<Double>

getQuantile

public Double getQuantile(double q)
                   throws QuantilesException

Specified by:

getQuantile in interface IQuantiles<Double>

Throws:

QuantilesException

setElementsPerBucket

public void setElementsPerBucket(int newCount)

getElementsPerBucket

public int getElementsPerBucket()

setMaxBucketCount

public void setMaxBucketCount(int newCount)

getMaxBucketCount

public int getMaxBucketCount()