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

Class FlussSourceReaderMetrics

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.metrics.FlussSourceReaderMetrics

public class FlussSourceReaderMetrics
extends Object

A collection class for handling metrics in the Fluss CDC source reader.

Field Summary

Fields

Modifier and Type	Field	Description
static long	UNINITIALIZED

Constructor Summary

Constructors

Constructor	Description
FlussSourceReaderMetrics(org.apache.flink.metrics.groups.SourceReaderMetricGroup sourceReaderMetricGroup)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.metrics.groups.SourceReaderMetricGroup	getSourceReaderMetricGroup()
void	reportRecordEventTime(long lag)

Methods inherited from class java.lang.Object

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

Field Detail

UNINITIALIZED

public static final long UNINITIALIZED

See Also:

Constant Field Values

Constructor Detail

FlussSourceReaderMetrics

public FlussSourceReaderMetrics(org.apache.flink.metrics.groups.SourceReaderMetricGroup sourceReaderMetricGroup)

Method Detail

reportRecordEventTime

public void reportRecordEventTime(long lag)

getSourceReaderMetricGroup

public org.apache.flink.metrics.groups.SourceReaderMetricGroup getSourceReaderMetricGroup()