Package io.debezium.metrics.stats

Class LongDDSketchStatistics<T extends SingleValueEvent<Long>>

java.lang.Object

io.debezium.metrics.stats.LongDDSketchStatistics<T>

All Implemented Interfaces:

MeasurementStatistics<T,Long>, Consumer<T>

@ThreadSafe
public class LongDDSketchStatistics<T extends SingleValueEvent<Long>>
extends Object
implements MeasurementStatistics<T,Long>

Implementation of MeasurementStatistics which is backed by DDSketch library.

Author:

vjuranek

Field Summary

Fields

Modifier and Type	Field	Description
private final com.datadoghq.sketch.ddsketch.DDSketch	sketch

Constructor Summary

Constructors

Constructor	Description
LongDDSketchStatistics()

Method Summary

Modifier and Type	Method	Description
void	accept(T event)
Double	getValueAtQuantile(double quantile)
void	reset()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface io.debezium.metrics.stats.MeasurementStatistics

getValueAtP50, getValueAtP95, getValueAtP99

Field Details

sketch

private final com.datadoghq.sketch.ddsketch.DDSketch sketch

Constructor Details

LongDDSketchStatistics

public LongDDSketchStatistics()

Method Details

accept

public void accept(T event)

Specified by:

accept in interface Consumer<T extends SingleValueEvent<Long>>

reset

public void reset()

Specified by:

reset in interface MeasurementStatistics<T extends SingleValueEvent<Long>,Long>

getValueAtQuantile

public Double getValueAtQuantile(double quantile)

Specified by:

getValueAtQuantile in interface MeasurementStatistics<T extends SingleValueEvent<Long>,Long>