Package 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 BeamMetricSets 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
    Description
    static WithMetricsSupport
    forRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
     
    SortedMap<String,com.codahale.metrics.Counter>
    getCounters(com.codahale.metrics.MetricFilter filter)
     
    SortedMap<String,com.codahale.metrics.Gauge>
    getGauges(com.codahale.metrics.MetricFilter filter)
     
    SortedMap<String,com.codahale.metrics.Histogram>
    getHistograms(com.codahale.metrics.MetricFilter filter)
     
    SortedMap<String,com.codahale.metrics.Meter>
    getMeters(com.codahale.metrics.MetricFilter filter)
     
    SortedMap<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 Details

    • forRegistry

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

    • getTimers

      public SortedMap<String,com.codahale.metrics.Timer> getTimers(com.codahale.metrics.MetricFilter filter)
      Overrides:
      getTimers in class com.codahale.metrics.MetricRegistry

    • getMeters

      public SortedMap<String,com.codahale.metrics.Meter> getMeters(com.codahale.metrics.MetricFilter filter)
      Overrides:
      getMeters in class com.codahale.metrics.MetricRegistry

    • getHistograms

      public SortedMap<String,com.codahale.metrics.Histogram> getHistograms(com.codahale.metrics.MetricFilter filter)
      Overrides:
      getHistograms in class com.codahale.metrics.MetricRegistry

    • getCounters

      public SortedMap<String,com.codahale.metrics.Counter> getCounters(com.codahale.metrics.MetricFilter filter)
      Overrides:
      getCounters in class com.codahale.metrics.MetricRegistry

    • getGauges

      public SortedMap<String,com.codahale.metrics.Gauge> getGauges(com.codahale.metrics.MetricFilter filter)
      Overrides:
      getGauges in class com.codahale.metrics.MetricRegistry