Class FloatingBuffersUsageGauge
- java.lang.Object
-
- org.apache.flink.runtime.io.network.metrics.AbstractBuffersUsageGauge
-
- org.apache.flink.runtime.io.network.metrics.FloatingBuffersUsageGauge
-
public class FloatingBuffersUsageGauge extends AbstractBuffersUsageGauge
Gauge metric measuring the floating buffers usage gauge forSingleInputGate
s.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.io.network.metrics.AbstractBuffersUsageGauge
inputGates
-
-
Constructor Summary
Constructors Constructor Description FloatingBuffersUsageGauge(SingleInputGate[] inputGates)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
calculateTotalBuffers(SingleInputGate inputGate)
int
calculateUsedBuffers(SingleInputGate inputGate)
-
Methods inherited from class org.apache.flink.runtime.io.network.metrics.AbstractBuffersUsageGauge
getValue
-
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.Gauge
getMetricType
-
-
-
-
Constructor Detail
-
FloatingBuffersUsageGauge
public FloatingBuffersUsageGauge(SingleInputGate[] inputGates)
-
-
Method Detail
-
calculateUsedBuffers
public int calculateUsedBuffers(SingleInputGate inputGate)
- Specified by:
calculateUsedBuffers
in classAbstractBuffersUsageGauge
-
calculateTotalBuffers
public int calculateTotalBuffers(SingleInputGate inputGate)
- Specified by:
calculateTotalBuffers
in classAbstractBuffersUsageGauge
-
-