org.apache.heron.kafka.spout.metrics

Class KafkaMetricDecorator<M extends org.apache.kafka.common.Metric>

java.lang.Object

org.apache.heron.kafka.spout.metrics.KafkaMetricDecorator<M>

All Implemented Interfaces:

org.apache.heron.api.metric.IMetric<Object>

public class KafkaMetricDecorator<M extends org.apache.kafka.common.Metric>
extends Object
implements org.apache.heron.api.metric.IMetric<Object>

a decorator to convert a Kafka Metric to a Heron Metric so that Kafka metrics can be exposed via Heron Metrics Manager

Constructor Summary

Constructors

Constructor and Description
KafkaMetricDecorator(M metric)

Method Summary

Modifier and Type	Method and Description
Object	getValueAndReset()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaMetricDecorator

public KafkaMetricDecorator(M metric)

Method Detail

getValueAndReset

public Object getValueAndReset()

Specified by:

getValueAndReset in interface org.apache.heron.api.metric.IMetric<Object>