This class is *not thread-safe*, safe consumption in a multi-threaded environment will require some form of external locking.
| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| private final double | |
| private final int | |
| private final double | |
| private final List | |
| private final int | |
| private static final double | |
| private static final int | |
| private static final double | |
| private static final double | |
| private final double[] | |
| private final double | |
| private final double | |
| private long | |
| private final long |
| Access | Constructor and Description |
|---|---|
| public | BarSplittingBiasedHistogram(double
relative split threshold maxCoefficient, double histogram bucket bias factor phi, int number of bars per bucket expansionFactor, int number of buckets bucketCount, double bar count relative error barEpsilon, long sliding window size window)Create a histogram maintained over a sliding time window. |
| public | BarSplittingBiasedHistogram(int
number of buckets bucketCount, long sliding window size window)Create a histogram maintained over a sliding time window. |
| public | BarSplittingBiasedHistogram(double
histogram bucket bias factor phi, int number of buckets bucketCount, long sliding window size window)Create a histogram maintained over a sliding time window. |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv double | |
| pack-priv List | |
| pack-priv int | |
| private double[] | |
| private double[] | |
| public void | event(double
event value value, long event time time)Implements org. value occuring at he given time
|
| public void | expire(long
current timestamp time)Implements org. |
| private int | |
| public List | getBuckets()
Implements org. |
| public double | getMaximum()
Overrides default org. |
| public double | getMinimum()
Overrides default org. |
| public double[] | getQuantileBounds(double
desired quantile quantile)Implements org. [minimum, maximum) on the given quantile.
|
| public double[] | |
| private double | |
| private int | |
| protected static double | |
| pack-priv double | |
| public long | |
| private void | |
| public String |
| alphaPhi | back to summary |
|---|---|
| private final double alphaPhi | |
| barCount | back to summary |
|---|---|
| private final int barCount | |
| barEpsilon | back to summary |
|---|---|
| private final double barEpsilon | |
| bars | back to summary |
|---|---|
| private final List<BarSplittingBiasedHistogram. | |
| bucketCount | back to summary |
|---|---|
| private final int bucketCount | |
| DEFAULT_EXP_HISTOGRAM_EPSILON | back to summary |
|---|---|
| private static final double DEFAULT_EXP_HISTOGRAM_EPSILON | |
| DEFAULT_EXPANSION_FACTOR | back to summary |
|---|---|
| private static final int DEFAULT_EXPANSION_FACTOR | |
| DEFAULT_MAX_COEFFICIENT | back to summary |
|---|---|
| private static final double DEFAULT_MAX_COEFFICIENT | |
| DEFAULT_PHI | back to summary |
|---|---|
| private static final double DEFAULT_PHI | |
| maxSizeTable | back to summary |
|---|---|
| private final double[] maxSizeTable | |
| phi | back to summary |
|---|---|
| private final double phi | |
| ratio | back to summary |
|---|---|
| private final double ratio | |
| size | back to summary |
|---|---|
| private long size | |
| window | back to summary |
|---|---|
| private final long window | |
| BarSplittingBiasedHistogram | back to summary |
|---|---|
| public BarSplittingBiasedHistogram(double maxCoefficient, double phi, int expansionFactor, int bucketCount, double barEpsilon, long window) Create a histogram maintained over a sliding time window. The constructed histogram is:
| |
| BarSplittingBiasedHistogram | back to summary |
|---|---|
| public BarSplittingBiasedHistogram(int bucketCount, long window) Create a histogram maintained over a sliding time window. The constructed histogram is:
| |
| BarSplittingBiasedHistogram | back to summary |
|---|---|
| public BarSplittingBiasedHistogram(double phi, int bucketCount, long window) Create a histogram maintained over a sliding time window. The constructed histogram is:
| |
| alphaPhi | back to summary |
|---|---|
| pack-priv double alphaPhi() | |
| bars | back to summary |
|---|---|
| pack-priv List | |
| bucketCount | back to summary |
|---|---|
| pack-priv int bucketCount() | |
| evaluateQuantileFromMax | back to summary |
|---|---|
| private double[] evaluateQuantileFromMax(double quantile) | |
| evaluateQuantileFromMin | back to summary |
|---|---|
| private double[] evaluateQuantileFromMin(double quantile) | |
| event | back to summary |
|---|---|
| public void event(double value, long time) Implements org. Record an event of the given
| |
| expire | back to summary |
|---|---|
| public void expire(long time) Implements org. Expire old events from all buckets.
| |
| getBarIndex | back to summary |
|---|---|
| private int getBarIndex(double value) | |
| getBuckets | back to summary |
|---|---|
| public List Implements org. Doc from org. Returns the histograms buckets | |
| getMaximum | back to summary |
|---|---|
| public double getMaximum() Overrides default org. Doc from org. The maximum value. This is equal to highest double value strictly less than the exclusive upper bound of the last (1.0) quantile.
| |
| getMinimum | back to summary |
|---|---|
| public double getMinimum() Overrides default org. Doc from org. The minimum value. This is equal to the inclusive lower bound of the zeroth (0.0) quantile.
| |
| getQuantileBounds | back to summary |
|---|---|
| public double[] getQuantileBounds(double quantile) Implements org. Doc from org. Returns the bounds
| |
| getSizeBounds | back to summary |
|---|---|
| public double[] getSizeBounds() Implements org.
| |
| maxBarSize | back to summary |
|---|---|
| private double maxBarSize(int barIndex) | |
| mergeBars | back to summary |
|---|---|
| private int mergeBars() | |
| nextUpIfEqual | back to summary |
|---|---|
| protected static double nextUpIfEqual(double test, double value) | |
| phi | back to summary |
|---|---|
| pack-priv double phi() | |
| size | back to summary |
|---|---|
| public long size() Implements org.
| |
| split | back to summary |
|---|---|
| private void split(BarSplittingBiasedHistogram. | |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object. | |
| Modifier and Type | Field and Description |
|---|---|
| private final ExponentialHistogram | |
| private double | |
| private double |
| Access | Constructor and Description |
|---|---|
| pack-priv | |
| private |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv long | |
| pack-priv double | |
| pack-priv long | |
| pack-priv void | |
| pack-priv double | |
| pack-priv void | |
| pack-priv double | |
| pack-priv BarSplittingBiasedHistogram. | |
| public String |
| eh | back to summary |
|---|---|
| private final ExponentialHistogram eh | |
| maximum | back to summary |
|---|---|
| private double maximum | |
| minimum | back to summary |
|---|---|
| private double minimum | |
| Bar | back to summary |
|---|---|
| pack-priv Bar(double epsilon, long window) | |
| Bar | back to summary |
|---|---|
| private Bar(ExponentialHistogram eh, double minimum, double maximum) | |
| count | back to summary |
|---|---|
| pack-priv long count() | |
| epsilon | back to summary |
|---|---|
| pack-priv double epsilon() | |
| expire | back to summary |
|---|---|
| pack-priv long expire(long time) | |
| insert | back to summary |
|---|---|
| pack-priv void insert(double value, long time) | |
| maximum | back to summary |
|---|---|
| pack-priv double maximum() | |
| merge | back to summary |
|---|---|
| pack-priv void merge(BarSplittingBiasedHistogram. | |
| minimum | back to summary |
|---|---|
| pack-priv double minimum() | |
| split | back to summary |
|---|---|
| pack-priv BarSplittingBiasedHistogram. | |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object. | |