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 java.lang.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 and Description
SparkBeamMetricSource(java.lang.String name, MetricsAccumulator metrics)

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

SparkBeamMetricSource

public SparkBeamMetricSource(java.lang.String name,
                             MetricsAccumulator metrics)

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