org.apache.flink.runtime.metrics.groups

Class TaskIOMetricGroup

java.lang.Object

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

org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup

All Implemented Interfaces:

MetricGroup

public class TaskIOMetricGroup
extends ProxyMetricGroup<TaskMetricGroup>

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

Field Summary

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

parentMetricGroup

Constructor Summary

Constructors

Constructor and Description
TaskIOMetricGroup(TaskMetricGroup parent)

Method Summary

Modifier and Type	Method and Description
IOMetrics	createSnapshot()
Counter	getNumBuffersInLocalCounter()
Counter	getNumBuffersInRemoteCounter()
Counter	getNumBuffersOutCounter()
Counter	getNumBytesInLocalCounter()
Meter	getNumBytesInLocalRateMeter()
Counter	getNumBytesInRemoteCounter()
Meter	getNumBytesInRemoteRateMeter()
Counter	getNumBytesOutCounter()
Meter	getNumBytesOutRateMeter()
Counter	getNumRecordsInCounter()
Counter	getNumRecordsOutCounter()
void	initializeBufferMetrics(Task task) Initialize Buffer Metrics for a task.
void	reuseRecordsInputCounter(Counter numRecordsInCounter)
void	reuseRecordsOutputCounter(Counter numRecordsOutCounter)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskIOMetricGroup

public TaskIOMetricGroup(TaskMetricGroup parent)

Method Detail

createSnapshot

public IOMetrics createSnapshot()

getNumBytesOutCounter

public Counter getNumBytesOutCounter()

getNumBytesInLocalCounter

public Counter getNumBytesInLocalCounter()

getNumBytesInRemoteCounter

public Counter getNumBytesInRemoteCounter()

getNumRecordsInCounter

public Counter getNumRecordsInCounter()

getNumRecordsOutCounter

public Counter getNumRecordsOutCounter()

getNumBuffersOutCounter

public Counter getNumBuffersOutCounter()

getNumBuffersInLocalCounter

public Counter getNumBuffersInLocalCounter()

getNumBuffersInRemoteCounter

public Counter getNumBuffersInRemoteCounter()

getNumBytesInLocalRateMeter

public Meter getNumBytesInLocalRateMeter()

getNumBytesInRemoteRateMeter

public Meter getNumBytesInRemoteRateMeter()

getNumBytesOutRateMeter

public Meter getNumBytesOutRateMeter()

initializeBufferMetrics

public void initializeBufferMetrics(Task task)

Initialize Buffer Metrics for a task.

reuseRecordsInputCounter

public void reuseRecordsInputCounter(Counter numRecordsInCounter)

reuseRecordsOutputCounter

public void reuseRecordsOutputCounter(Counter numRecordsOutCounter)