org.apache.flink.runtime.io.network.metrics

Class InputChannelMetrics

java.lang.Object

org.apache.flink.runtime.io.network.metrics.InputChannelMetrics

public class InputChannelMetrics
extends Object

Collects metrics for RemoteInputChannel and LocalInputChannel.

Constructor Summary

Constructors

Constructor and Description
InputChannelMetrics(MetricGroup... parents)

Method Summary

Modifier and Type	Method and Description
Counter	getNumBuffersInLocalCounter()
Counter	getNumBuffersInRemoteCounter()
Counter	getNumBytesInLocalCounter()
Counter	getNumBytesInRemoteCounter()

Methods inherited from class java.lang.Object

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

Constructor Detail

InputChannelMetrics

public InputChannelMetrics(MetricGroup... parents)

Method Detail

getNumBytesInLocalCounter

public Counter getNumBytesInLocalCounter()

getNumBytesInRemoteCounter

public Counter getNumBytesInRemoteCounter()

getNumBuffersInLocalCounter

public Counter getNumBuffersInLocalCounter()

getNumBuffersInRemoteCounter

public Counter getNumBuffersInRemoteCounter()