stream.scotty.demo.flink.windowFunctions

Class QuantileTreeMap

java.lang.Object

windowFunctions.flink.demo.stream.scotty.QuantileTreeMap

All Implemented Interfaces:

java.io.Serializable

public class QuantileTreeMap
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	counter
private int	lowercount
private double	pct
private int	quantile
private int	uppercount
private java.util.TreeMap<java.lang.Integer,java.lang.Integer>	values

Constructor Summary

Constructors

Modifier	Constructor and Description
	QuantileTreeMap(java.lang.Integer initialValue, double pct)
private	QuantileTreeMap(int quantile, int lowercount, int uppercount, double pct, java.util.TreeMap<java.lang.Integer,java.lang.Integer> values)

Method Summary

Modifier and Type	Method and Description
QuantileTreeMap	addValue(java.lang.Integer value)
void	addValues(java.util.TreeMap<java.lang.Integer,java.lang.Integer> newValues)
QuantileTreeMap	clone()
boolean	equals(java.lang.Object o)
int	getQuantile()
java.util.TreeMap<java.lang.Integer,java.lang.Integer>	getValues()
int	hashCode()
QuantileTreeMap	merge(QuantileTreeMap q) Merges another quantile into this one.
private void	updateQuantile()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

values

private java.util.TreeMap<java.lang.Integer,java.lang.Integer> values

quantile

private int quantile

lowercount

private int lowercount

uppercount

private int uppercount

pct

private double pct

counter

public static int counter

Constructor Detail

QuantileTreeMap

public QuantileTreeMap(java.lang.Integer initialValue,
                       double pct)

QuantileTreeMap

private QuantileTreeMap(int quantile,
                        int lowercount,
                        int uppercount,
                        double pct,
                        java.util.TreeMap<java.lang.Integer,java.lang.Integer> values)

Method Detail

addValue

public QuantileTreeMap addValue(java.lang.Integer value)

addValues

public void addValues(java.util.TreeMap<java.lang.Integer,java.lang.Integer> newValues)

merge

public QuantileTreeMap merge(QuantileTreeMap q)

Merges another quantile into this one. Be aware that this method returns the same object. This method will NOT clone the Quantile object for merging it.

Parameters:

q - the quantile to merge

Returns:

this object: This method will NOT clone the Quantile object for merging it.

getValues

public java.util.TreeMap<java.lang.Integer,java.lang.Integer> getValues()

getQuantile

public int getQuantile()

updateQuantile

private void updateQuantile()

clone

public QuantileTreeMap clone()

Overrides:

clone in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object