Package io.debezium.metrics.stats

Class SingleValueLongMeasurementWithStats<T extends SingleValueEvent<Long>>

java.lang.Object

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

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

All Implemented Interfaces:

Measurement<T>, MeasurementStatistics<T,Long>, SingleValueMeasurement<T,Long>, Consumer<T>

Direct Known Subclasses:

LagBehindSourceMeasurement

@ThreadSafe
public abstract class SingleValueLongMeasurementWithStats<T extends SingleValueEvent<Long>>
extends SingleValueLongMeasurement<T>
implements MeasurementStatistics<T,Long>

SingleValueMeasurement of Long type, which provides support of more advanced statistics like quantiles.

Author:

vjuranek

Field Summary

Fields

Modifier and Type	Field	Description
private final MeasurementStatistics<T,Long>	statistics

Constructor Summary

Constructors

Constructor	Description
SingleValueLongMeasurementWithStats(MeasurementStatistics<T,Long> statistics)

Method Summary

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

Methods inherited from class io.debezium.metrics.stats.SingleValueLongMeasurement

getAverageValue, getLastValue, getMaxValue, getMinValue, getSum

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

statistics

private final MeasurementStatistics<T extends SingleValueEvent<Long>,Long> statistics

Constructor Details

SingleValueLongMeasurementWithStats

public SingleValueLongMeasurementWithStats(MeasurementStatistics<T,Long> statistics)

Method Details

getValueAtQuantile

public Double getValueAtQuantile(double quantile)

Specified by:

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

accept

public void accept(T event)

Specified by:

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

Specified by:

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

Overrides:

accept in class SingleValueLongMeasurement<T extends SingleValueEvent<Long>>

reset

public void reset()

Specified by:

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

Specified by:

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

Overrides:

reset in class SingleValueLongMeasurement<T extends SingleValueEvent<Long>>