SparkBeamMetricSource (Apache Beam 2.69.0)

java.lang.Object

org.apache.beam.runners.spark.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)
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)
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