SourceReaderMetrics (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.base.source.metrics.SourceReaderMetrics

```
public class SourceReaderMetrics
extends Object
```
A collection class for handling metrics in IncrementalSourceReader.

Field Summary

Fields
Modifier and Type	Field	Description
`static String`	`CURRENT_EVENT_TIME_LAG`
`static String`	`NAMESPACE_GROUP_KEY`
`static String`	`NUM_DDL_RECORDS`
`static String`	`NUM_DELETE_DML_RECORDS`
`static String`	`NUM_INSERT_DML_RECORDS`
`static String`	`NUM_SNAPSHOT_RECORDS`
`static String`	`NUM_UPDATE_DML_RECORDS`
`static String`	`SCHEMA_GROUP_KEY`
`static String`	`TABLE_GROUP_KEY`
`static long`	`UNDEFINED`

Constructor Summary

Constructors
Constructor Description

SourceReaderMetrics(org.apache.flink.metrics.groups.SourceReaderMetricGroup metricGroup)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addNumRecordsInErrors(long delta)`
`long`	`getFetchDelay()`
`void`	`markRecord()`
`void`	`recordFetchDelay(long fetchDelay)`
`void`	`updateLastReceivedEventTime(Long eventTimestamp)`
`void`	`updateRecordCounters(org.apache.kafka.connect.source.SourceRecord record)`

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
- NAMESPACE_GROUP_KEY
```
public static final String NAMESPACE_GROUP_KEY
```
  See Also:
  
  Constant Field Values
- SCHEMA_GROUP_KEY
```
public static final String SCHEMA_GROUP_KEY
```
  See Also:
  
  Constant Field Values
- TABLE_GROUP_KEY
```
public static final String TABLE_GROUP_KEY
```
  See Also:
  
  Constant Field Values
- NUM_SNAPSHOT_RECORDS
```
public static final String NUM_SNAPSHOT_RECORDS
```
  See Also:
  
  Constant Field Values
- NUM_INSERT_DML_RECORDS
```
public static final String NUM_INSERT_DML_RECORDS
```
  See Also:
  
  Constant Field Values
- NUM_UPDATE_DML_RECORDS
```
public static final String NUM_UPDATE_DML_RECORDS
```
  See Also:
  
  Constant Field Values
- NUM_DELETE_DML_RECORDS
```
public static final String NUM_DELETE_DML_RECORDS
```
  See Also:
  
  Constant Field Values
- NUM_DDL_RECORDS
```
public static final String NUM_DDL_RECORDS
```
  See Also:
  
  Constant Field Values
- CURRENT_EVENT_TIME_LAG
```
public static final String CURRENT_EVENT_TIME_LAG
```
  See Also:
  
  Constant Field Values

Constructor Detail

SourceReaderMetrics

public SourceReaderMetrics(org.apache.flink.metrics.groups.SourceReaderMetricGroup metricGroup)

Method Detail

getFetchDelay
```
public long getFetchDelay()
```

recordFetchDelay

public void recordFetchDelay(long fetchDelay)

addNumRecordsInErrors

public void addNumRecordsInErrors(long delta)

updateLastReceivedEventTime

public void updateLastReceivedEventTime(Long eventTimestamp)

markRecord
```
public void markRecord()
```

updateRecordCounters

public void updateRecordCounters(org.apache.kafka.connect.source.SourceRecord record)