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

Class AbstractBuffersUsageGauge

java.lang.Object

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

All Implemented Interfaces:

Gauge<Float>, Metric

Direct Known Subclasses:

CreditBasedInputBuffersUsageGauge, ExclusiveBuffersUsageGauge, FloatingBuffersUsageGauge

public abstract class AbstractBuffersUsageGauge
extends Object
implements Gauge<Float>

Abstract gauge implementation for calculating the buffer usage percent.

Field Summary

Fields

Modifier and Type	Field and Description
protected SingleInputGate[]	inputGates

Method Summary

Modifier and Type	Method and Description
abstract int	calculateTotalBuffers(SingleInputGate inputGate)
abstract int	calculateUsedBuffers(SingleInputGate inputGate)
Float	getValue() Calculates and returns the measured value.

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

Field Detail

inputGates

protected final SingleInputGate[] inputGates

Method Detail

calculateUsedBuffers

@VisibleForTesting
public abstract int calculateUsedBuffers(SingleInputGate inputGate)

calculateTotalBuffers

@VisibleForTesting
public abstract int calculateTotalBuffers(SingleInputGate inputGate)

getValue

public Float getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<Float>

Returns:

calculated value