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

Class CompositeSource

java.lang.Object

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

All Implemented Interfaces:

org.apache.spark.metrics.source.Source

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

Composite source made up of several MetricRegistry instances.

Constructor Summary

Constructors

Constructor and Description
CompositeSource(java.lang.String name, com.codahale.metrics.MetricRegistry... metricRegistries)

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

CompositeSource

public CompositeSource(java.lang.String name,
                       com.codahale.metrics.MetricRegistry... metricRegistries)

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