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

Class WithMetricsSupport

java.lang.Object

com.codahale.metrics.MetricRegistry

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

All Implemented Interfaces:

com.codahale.metrics.Metric, com.codahale.metrics.MetricSet

public class WithMetricsSupport
extends com.codahale.metrics.MetricRegistry

A MetricRegistry decorator-like that supports AggregatorMetric and SparkBeamMetric as Gauges.

MetricRegistry is not an interface, so this is not a by-the-book decorator. That said, it delegates all metric related getters to the "decorated" instance.

Nested Class Summary

Nested classes/interfaces inherited from class com.codahale.metrics.MetricRegistry

com.codahale.metrics.MetricRegistry.MetricSupplier<T extends com.codahale.metrics.Metric>

Method Summary

Modifier and Type	Method and Description
static WithMetricsSupport	forRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
java.util.SortedMap<java.lang.String,com.codahale.metrics.Counter>	getCounters(com.codahale.metrics.MetricFilter filter)
java.util.SortedMap<java.lang.String,com.codahale.metrics.Gauge>	getGauges(com.codahale.metrics.MetricFilter filter)
java.util.SortedMap<java.lang.String,com.codahale.metrics.Histogram>	getHistograms(com.codahale.metrics.MetricFilter filter)
java.util.SortedMap<java.lang.String,com.codahale.metrics.Meter>	getMeters(com.codahale.metrics.MetricFilter filter)
java.util.SortedMap<java.lang.String,com.codahale.metrics.Timer>	getTimers(com.codahale.metrics.MetricFilter filter)

Methods inherited from class com.codahale.metrics.MetricRegistry

addListener, buildMap, counter, counter, gauge, getCounters, getGauges, getHistograms, getMeters, getMetrics, getNames, getTimers, histogram, histogram, meter, meter, name, name, register, registerAll, remove, removeListener, removeMatching, timer, timer

Methods inherited from class java.lang.Object

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

Method Detail

forRegistry

public static WithMetricsSupport forRegistry(com.codahale.metrics.MetricRegistry metricRegistry)

getTimers

public java.util.SortedMap<java.lang.String,com.codahale.metrics.Timer> getTimers(com.codahale.metrics.MetricFilter filter)

Overrides:

getTimers in class com.codahale.metrics.MetricRegistry

getMeters

public java.util.SortedMap<java.lang.String,com.codahale.metrics.Meter> getMeters(com.codahale.metrics.MetricFilter filter)

Overrides:

getMeters in class com.codahale.metrics.MetricRegistry

getHistograms

public java.util.SortedMap<java.lang.String,com.codahale.metrics.Histogram> getHistograms(com.codahale.metrics.MetricFilter filter)

Overrides:

getHistograms in class com.codahale.metrics.MetricRegistry

getCounters

public java.util.SortedMap<java.lang.String,com.codahale.metrics.Counter> getCounters(com.codahale.metrics.MetricFilter filter)

Overrides:

getCounters in class com.codahale.metrics.MetricRegistry

getGauges

public java.util.SortedMap<java.lang.String,com.codahale.metrics.Gauge> getGauges(com.codahale.metrics.MetricFilter filter)

Overrides:

getGauges in class com.codahale.metrics.MetricRegistry