org.apache.flink.metrics.groups

Interface OperatorIOMetricGroup

All Superinterfaces:

MetricGroup

All Known Implementing Classes:

InternalOperatorIOMetricGroup

@PublicEvolving
public interface OperatorIOMetricGroup
extends MetricGroup

Metric group that contains shareable pre-defined IO-related metrics for operators.

You should only update the metrics in the main operator thread.

Method Summary

Modifier and Type	Method and Description
Counter	getNumBytesInCounter() The total number of input bytes since the task started.
Counter	getNumBytesOutCounter() The total number of output bytes since the task started.
Counter	getNumRecordsInCounter() The total number of input records since the operator started.
Counter	getNumRecordsOutCounter() The total number of output records since the operator started.

Methods inherited from interface org.apache.flink.metrics.MetricGroup

addGroup, addGroup, addGroup, counter, counter, counter, counter, gauge, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, meter, meter

Method Detail

getNumRecordsInCounter

Counter getNumRecordsInCounter()

The total number of input records since the operator started. Will also populate numRecordsInPerSecond meter.

getNumRecordsOutCounter

Counter getNumRecordsOutCounter()

The total number of output records since the operator started. Will also populate numRecordsOutPerSecond meter.

getNumBytesInCounter

Counter getNumBytesInCounter()

The total number of input bytes since the task started. Will also populate numBytesInPerSecond meter.

getNumBytesOutCounter

Counter getNumBytesOutCounter()

The total number of output bytes since the task started. Will also populate numBytesOutPerSecond meter.