Package org.apache.flink.metrics.groups
Interface OperatorIOMetricGroup
-
- All Superinterfaces:
MetricGroup
@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 CountergetNumBytesInCounter()The total number of input bytes since the task started.CountergetNumBytesOutCounter()The total number of output bytes since the task started.CountergetNumRecordsInCounter()The total number of input records since the operator started.CountergetNumRecordsOutCounter()The total number of output records since the operator started.-
Methods inherited from interface org.apache.flink.metrics.MetricGroup
addEvent, 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.
-
-