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

Class SparkBeamMetricSource

java.lang.Object

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

All Implemented Interfaces:

org.apache.spark.metrics.source.Source

public class SparkBeamMetricSource
extends Object
implements org.apache.spark.metrics.source.Source

A Spark Source that is tailored to expose a SparkBeamMetric, wrapping an underlying MetricResults instance.

Constructor Summary

Constructors

Constructor	Description
SparkBeamMetricSource(String name, MetricsAccumulator metrics)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SparkBeamMetricSource

public SparkBeamMetricSource(String name,
 MetricsAccumulator metrics)

Method Details

sourceName

public 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