Package io.debezium.pipeline.meters

Class StreamingMeter

java.lang.Object

io.debezium.pipeline.meters.StreamingMeter

All Implemented Interfaces:

SchemaMetricsMXBean, StreamingMetricsMXBean, StreamingStatisticsMXBean

@ThreadSafe
public class StreamingMeter
extends Object
implements StreamingMetricsMXBean, StreamingStatisticsMXBean

Carries streaming metrics.

Field Summary

Fields

Modifier and Type	Field	Description
private final CapturedTablesSupplier	capturedTablesSupplier
private final LagBehindSourceMeasurement	lagBehindSourceMeasurement
private final AtomicReference<String>	lastTransactionId
private final MeasurementCollector<LagBehindSourceEvent>	measurementCollector
private final EventMetadataProvider	metadataProvider
private final AtomicLong	numberOfCommittedTransactions
private final AtomicLong	numberOfUnchangedEventsSkipped
private final AtomicReference<Map<String,String>>	sourceEventPosition

Constructor Summary

Constructors

Constructor	Description
StreamingMeter(CommonConnectorConfig config, CapturedTablesSupplier capturedTablesSupplier, EventMetadataProvider metadataProvider)

Method Summary

Modifier and Type	Method	Description
void	enableUnchangedEventsMetric()
String[]	getCapturedTables()
String	getLastTransactionId()
long	getMilliSecondsBehindSource()
Double	getMilliSecondsBehindSourceAverageValue()
Long	getMilliSecondsBehindSourceMaxValue()
Long	getMilliSecondsBehindSourceMinValue()
Double	getMilliSecondsBehindSourceP50()
Double	getMilliSecondsBehindSourceP95()
Double	getMilliSecondsBehindSourceP99()
long	getNumberOfCommittedTransactions()
long	getNumberOfUnchangedEventsSkipped()
Map<String,String>	getSourceEventPosition()
void	onEvent(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
void	onUnchangedEventSkipped()
void	reset()
void	resetLagBehindSource()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

numberOfCommittedTransactions

private final AtomicLong numberOfCommittedTransactions

sourceEventPosition

private final AtomicReference<Map<String,String>> sourceEventPosition

lastTransactionId

private final AtomicReference<String> lastTransactionId

numberOfUnchangedEventsSkipped

private final AtomicLong numberOfUnchangedEventsSkipped

measurementCollector

private final MeasurementCollector<LagBehindSourceEvent> measurementCollector

lagBehindSourceMeasurement

private final LagBehindSourceMeasurement lagBehindSourceMeasurement

capturedTablesSupplier

private final CapturedTablesSupplier capturedTablesSupplier

metadataProvider

private final EventMetadataProvider metadataProvider

Constructor Details

StreamingMeter

public StreamingMeter(CommonConnectorConfig config,
 CapturedTablesSupplier capturedTablesSupplier,
 EventMetadataProvider metadataProvider)

Method Details

getCapturedTables

public String[] getCapturedTables()

Specified by:

getCapturedTables in interface SchemaMetricsMXBean

getSourceEventPosition

public Map<String,String> getSourceEventPosition()

Specified by:

getSourceEventPosition in interface StreamingMetricsMXBean

getMilliSecondsBehindSource

public long getMilliSecondsBehindSource()

Specified by:

getMilliSecondsBehindSource in interface StreamingMetricsMXBean

getMilliSecondsBehindSourceMinValue

public Long getMilliSecondsBehindSourceMinValue()

Specified by:

getMilliSecondsBehindSourceMinValue in interface StreamingStatisticsMXBean

getMilliSecondsBehindSourceMaxValue

public Long getMilliSecondsBehindSourceMaxValue()

Specified by:

getMilliSecondsBehindSourceMaxValue in interface StreamingStatisticsMXBean

getMilliSecondsBehindSourceAverageValue

public Double getMilliSecondsBehindSourceAverageValue()

Specified by:

getMilliSecondsBehindSourceAverageValue in interface StreamingStatisticsMXBean

getMilliSecondsBehindSourceP50

public Double getMilliSecondsBehindSourceP50()

Specified by:

getMilliSecondsBehindSourceP50 in interface StreamingStatisticsMXBean

getMilliSecondsBehindSourceP95

public Double getMilliSecondsBehindSourceP95()

Specified by:

getMilliSecondsBehindSourceP95 in interface StreamingStatisticsMXBean

getMilliSecondsBehindSourceP99

public Double getMilliSecondsBehindSourceP99()

Specified by:

getMilliSecondsBehindSourceP99 in interface StreamingStatisticsMXBean

getNumberOfCommittedTransactions

public long getNumberOfCommittedTransactions()

Specified by:

getNumberOfCommittedTransactions in interface StreamingMetricsMXBean

getLastTransactionId

public String getLastTransactionId()

Specified by:

getLastTransactionId in interface StreamingMetricsMXBean

getNumberOfUnchangedEventsSkipped

public long getNumberOfUnchangedEventsSkipped()

Specified by:

getNumberOfUnchangedEventsSkipped in interface StreamingMetricsMXBean

resetLagBehindSource

public void resetLagBehindSource()

Specified by:

resetLagBehindSource in interface StreamingMetricsMXBean

enableUnchangedEventsMetric

public void enableUnchangedEventsMetric()

onUnchangedEventSkipped

public void onUnchangedEventSkipped()

onEvent

public void onEvent(io.debezium.spi.schema.DataCollectionId source,
 OffsetContext offset,
 Object key,
 org.apache.kafka.connect.data.Struct value)

start

public void start()

stop

public void stop()

reset

public void reset()