Package org.apache.flink.runtime.metrics.groups

Class InternalOperatorIOMetricGroup

java.lang.Object

org.apache.flink.runtime.metrics.groups.ProxyMetricGroup<InternalOperatorMetricGroup>

org.apache.flink.runtime.metrics.groups.InternalOperatorIOMetricGroup

All Implemented Interfaces:

OperatorIOMetricGroup, MetricGroup

@Internal
public class InternalOperatorIOMetricGroup
extends ProxyMetricGroup<InternalOperatorMetricGroup>
implements OperatorIOMetricGroup

Metric group that contains shareable pre-defined IO-related metrics. The metrics registration is forwarded to the parent operator metric group.

Field Summary

Fields inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

parentMetricGroup

Constructor Summary

Constructors

Constructor	Description
InternalOperatorIOMetricGroup(InternalOperatorMetricGroup parentMetricGroup)

Method Summary

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.
Meter	getNumRecordsInRateMeter()
Counter	getNumRecordsOutCounter()	The total number of output records since the operator started.
Meter	getNumRecordsOutRate()
void	reuseBytesInputMetricsForTask()	Causes the containing task to use this operators input bytes counter.
void	reuseBytesOutputMetricsForTask()	Causes the containing task to use this operators output bytes counter.
void	reuseInputMetricsForTask()	Causes the containing task to use this operators input record counter.
void	reuseOutputMetricsForTask()	Causes the containing task to use this operators output record counter.

Methods inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Constructor Detail

InternalOperatorIOMetricGroup

public InternalOperatorIOMetricGroup(InternalOperatorMetricGroup parentMetricGroup)

Method Detail

getNumRecordsInCounter

public Counter getNumRecordsInCounter()

Description copied from interface: OperatorIOMetricGroup

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

Specified by:

getNumRecordsInCounter in interface OperatorIOMetricGroup

getNumRecordsOutCounter

public Counter getNumRecordsOutCounter()

Description copied from interface: OperatorIOMetricGroup

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

Specified by:

getNumRecordsOutCounter in interface OperatorIOMetricGroup

getNumRecordsInRateMeter

public Meter getNumRecordsInRateMeter()

getNumRecordsOutRate

public Meter getNumRecordsOutRate()

getNumBytesInCounter

public Counter getNumBytesInCounter()

Description copied from interface: OperatorIOMetricGroup

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

Specified by:

getNumBytesInCounter in interface OperatorIOMetricGroup

getNumBytesOutCounter

public Counter getNumBytesOutCounter()

Description copied from interface: OperatorIOMetricGroup

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

Specified by:

getNumBytesOutCounter in interface OperatorIOMetricGroup

reuseInputMetricsForTask

public void reuseInputMetricsForTask()

Causes the containing task to use this operators input record counter.

reuseOutputMetricsForTask

public void reuseOutputMetricsForTask()

Causes the containing task to use this operators output record counter.

reuseBytesInputMetricsForTask

public void reuseBytesInputMetricsForTask()

Causes the containing task to use this operators input bytes counter.

reuseBytesOutputMetricsForTask

public void reuseBytesOutputMetricsForTask()

Causes the containing task to use this operators output bytes counter.