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

Class MaxKafkaMetricAccumulator

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, Cloneable, Accumulator<Void,Double>

public class MaxKafkaMetricAccumulator
extends DefaultKafkaMetricAccumulator

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.streaming.connectors.kafka.internals.metrics.DefaultKafkaMetricAccumulator

isMerged, kafkaMetric, mergedValue

Constructor Summary

Constructors

Constructor and Description
MaxKafkaMetricAccumulator(org.apache.kafka.common.metrics.KafkaMetric kafkaMetric)

Method Summary

Modifier and Type	Method and Description
Accumulator<Void,Double>	clone() Duplicates the accumulator.
void	merge(Accumulator<Void,Double> other) Used by system internally to merge the collected parts of an accumulator at the end of the job.

Methods inherited from class org.apache.flink.streaming.connectors.kafka.internals.metrics.DefaultKafkaMetricAccumulator

add, createFor, getLocalValue, getMeasurableFromKafkaMetric, resetLocal, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxKafkaMetricAccumulator

public MaxKafkaMetricAccumulator(org.apache.kafka.common.metrics.KafkaMetric kafkaMetric)

Method Detail

merge

public void merge(Accumulator<Void,Double> other)

Description copied from interface: Accumulator

Used by system internally to merge the collected parts of an accumulator at the end of the job.

Specified by:

merge in interface Accumulator<Void,Double>

Overrides:

merge in class DefaultKafkaMetricAccumulator

Parameters:

other - Reference to accumulator to merge in.

clone

public Accumulator<Void,Double> clone()

Description copied from interface: Accumulator

Duplicates the accumulator. All subclasses need to properly implement cloning and cannot throw a CloneNotSupportedException

Specified by:

clone in interface Accumulator<Void,Double>

Overrides:

clone in class DefaultKafkaMetricAccumulator

Returns:

The duplicated accumulator.