org.apache.beam.runners.spark.structuredstreaming.metrics

Class AggregatorMetric

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.metrics.AggregatorMetric

All Implemented Interfaces:

com.codahale.metrics.Metric

public class AggregatorMetric
extends java.lang.Object
implements com.codahale.metrics.Metric

An adapter between the NamedAggregators and Codahale's Metric interface.

Method Summary

Modifier and Type	Method and Description
static AggregatorMetric	of(NamedAggregators namedAggregators)

Methods inherited from class java.lang.Object

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

Method Detail

of

public static AggregatorMetric of(NamedAggregators namedAggregators)