Package io.debezium.metrics.stats

Class LagBehindSourceMeasurement

java.lang.Object

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

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

io.debezium.metrics.stats.LagBehindSourceMeasurement

All Implemented Interfaces:

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

public class LagBehindSourceMeasurement
extends SingleValueLongMeasurementWithStats<LagBehindSourceEvent>

Measurement of the lag between the time when a record was inserted into the source database and when it was processed by Debezium.

Author:

vjuranek

Constructor Summary

Constructors

Constructor	Description
LagBehindSourceMeasurement(MeasurementStatistics<LagBehindSourceEvent,Long> statistics)

Method Summary

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

accept, getValueAtQuantile, 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

Constructor Details

LagBehindSourceMeasurement

public LagBehindSourceMeasurement(MeasurementStatistics<LagBehindSourceEvent,Long> statistics)