Package 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
All Methods Instance Methods Abstract Methods Modifier and Type Method 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, addSpan, 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.
-
-