org.apache.flink.streaming.connectors.kafka.internals.metrics

Class KafkaMetricMutableWrapper

java.lang.Object

org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper

All Implemented Interfaces:

Gauge<Double>, Metric

@Internal
public class KafkaMetricMutableWrapper
extends Object
implements Gauge<Double>

Gauge for getting the current value of a Kafka metric.

Constructor Summary

Constructors

Constructor and Description
KafkaMetricMutableWrapper(org.apache.kafka.common.Metric metric)

Method Summary

Modifier and Type	Method and Description
Double	getValue() Calculates and returns the measured value.
void	setKafkaMetric(org.apache.kafka.common.Metric kafkaMetric)

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

KafkaMetricMutableWrapper

public KafkaMetricMutableWrapper(org.apache.kafka.common.Metric metric)

Method Detail

getValue

public Double getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<Double>

Returns:

calculated value

setKafkaMetric

public void setKafkaMetric(org.apache.kafka.common.Metric kafkaMetric)