Package org.apache.flink.cdc.connectors.mysql.source.metrics

Class MySqlSourceReaderMetrics

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics

public class MySqlSourceReaderMetrics
extends Object

A collection class for handling metrics in MySqlSourceReader.

Field Summary

Fields

Modifier and Type	Field	Description
static long	UNDEFINED

Constructor Summary

Constructors

Constructor	Description
MySqlSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

Modifier and Type	Method	Description
long	getFetchDelay()
void	recordFetchDelay(long fetchDelay)
void	registerMetrics()

Methods inherited from class java.lang.Object

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

Field Detail

UNDEFINED

public static final long UNDEFINED

See Also:

Constant Field Values

Constructor Detail

MySqlSourceReaderMetrics

public MySqlSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metricGroup)

Method Detail

registerMetrics

public void registerMetrics()

getFetchDelay

public long getFetchDelay()

recordFetchDelay

public void recordFetchDelay(long fetchDelay)