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

Class AggregatorMetricSource

java.lang.Object

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

All Implemented Interfaces:

org.apache.spark.metrics.source.Source

public class AggregatorMetricSource
extends java.lang.Object
implements org.apache.spark.metrics.source.Source

A Spark Source that is tailored to expose an AggregatorMetric, wrapping an underlying NamedAggregators instance.

Constructor Summary

Constructors

Constructor and Description
AggregatorMetricSource(java.lang.String name, NamedAggregators aggregators)

Method Summary

Modifier and Type	Method and Description
com.codahale.metrics.MetricRegistry	metricRegistry()
java.lang.String	sourceName()

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorMetricSource

public AggregatorMetricSource(java.lang.String name,
                              NamedAggregators aggregators)

Method Detail

sourceName

public java.lang.String sourceName()

Specified by:

sourceName in interface org.apache.spark.metrics.source.Source

metricRegistry

public com.codahale.metrics.MetricRegistry metricRegistry()

Specified by:

metricRegistry in interface org.apache.spark.metrics.source.Source