Package io.debezium.metrics.stats

Class SingleValueLongMeasurement<T extends SingleValueEvent<Long>>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

SingleValueLongMeasurementWithStats

@ThreadSafe
public abstract class SingleValueLongMeasurement<T extends SingleValueEvent<Long>>
extends Object
implements SingleValueMeasurement<T,Long>

SingleValueMeasurement whole measured variable type is Long type

Author:

vjuranek

Field Summary

Fields

Modifier and Type	Field	Description
private long	count
private long	lastValue
private long	maxValue
private long	minValue
private long	sum

Constructor Summary

Constructors

Constructor	Description
SingleValueLongMeasurement()

Method Summary

Modifier and Type	Method	Description
void	accept(T event)
Double	getAverageValue()
Long	getLastValue()
Long	getMaxValue()
Long	getMinValue()
Long	getSum()
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

Field Details

minValue

private long minValue

maxValue

private long maxValue

lastValue

private long lastValue

count

private long count

sum

private long sum

Constructor Details

SingleValueLongMeasurement

public SingleValueLongMeasurement()

Method Details

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>>

reset

public void reset()

Specified by:

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

getLastValue

public Long getLastValue()

Specified by:

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

getMinValue

public Long getMinValue()

Specified by:

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

getMaxValue

public Long getMaxValue()

Specified by:

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

getSum

public Long getSum()

Specified by:

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

getAverageValue

public Double getAverageValue()

Specified by:

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