Package org.apache.flink.runtime.io.network.partition.hybrid

Class HsOutputMetrics

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.HsOutputMetrics

public class HsOutputMetrics
extends Object

All metrics that HsResultPartition needs to count, except numBytesProduced.

Constructor Summary

Constructors

Constructor	Description
HsOutputMetrics(org.apache.flink.metrics.Counter numBytesOut, org.apache.flink.metrics.Counter numBuffersOut, TimerGauge hardBackpressureTimerGauge)

Method Summary

Modifier and Type	Method	Description
TimerGauge	getHardBackpressureTimerGauge()
org.apache.flink.metrics.Counter	getNumBuffersOut()
org.apache.flink.metrics.Counter	getNumBytesOut()

Methods inherited from class java.lang.Object

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

Constructor Detail

HsOutputMetrics

public HsOutputMetrics(org.apache.flink.metrics.Counter numBytesOut,
                       org.apache.flink.metrics.Counter numBuffersOut,
                       TimerGauge hardBackpressureTimerGauge)

Method Detail

getNumBytesOut

public org.apache.flink.metrics.Counter getNumBytesOut()

getNumBuffersOut

public org.apache.flink.metrics.Counter getNumBuffersOut()

getHardBackpressureTimerGauge

public TimerGauge getHardBackpressureTimerGauge()