SourceReaderMetricGroup (Flink : 2.0-SNAPSHOT API)

All Superinterfaces:

MetricGroup, OperatorMetricGroup

All Known Implementing Classes:

InternalSourceReaderMetricGroup
```
@PublicEvolving
public interface SourceReaderMetricGroup
extends OperatorMetricGroup
```
Pre-defined metrics for SourceReader.
You should only update the metrics in the main operator thread.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`Counter`	`getNumRecordsInErrorsCounter()`	The total number of record that failed to consume, process, or emit.
`void`	`setPendingBytesGauge(Gauge<Long> pendingBytesGauge)`	Sets an optional gauge for the number of bytes that have not been fetched by the source. e.g.
`void`	`setPendingRecordsGauge(Gauge<Long> pendingRecordsGauge)`	Sets an optional gauge for the number of records that have not been fetched by the source.

Methods inherited from interface org.apache.flink.metrics.MetricGroup
addGroup, addGroup, addGroup, addSpan, counter, counter, counter, counter, gauge, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, meter, meter

Methods inherited from interface org.apache.flink.metrics.groups.OperatorMetricGroup
getIOMetricGroup

- Method Detail
  - getNumRecordsInErrorsCounter
```
Counter getNumRecordsInErrorsCounter()
```
    The total number of record that failed to consume, process, or emit.
  - setPendingBytesGauge
```
void setPendingBytesGauge(Gauge<Long> pendingBytesGauge)
```
    Sets an optional gauge for the number of bytes that have not been fetched by the source. e.g. the remaining bytes in a file after the file descriptor reading position.
    Note that not every source can report this metric in an plausible and efficient way.
  - setPendingRecordsGauge
```
void setPendingRecordsGauge(Gauge<Long> pendingRecordsGauge)
```
    Sets an optional gauge for the number of records that have not been fetched by the source. e.g. the available records after the consumer offset in a Kafka partition.
    Note that not every source can report this metric in an plausible and efficient way.