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

Class CodahaleGraphiteSink

java.lang.Object

org.apache.spark.metrics.sink.GraphiteSink

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

All Implemented Interfaces:

org.apache.spark.metrics.sink.Sink

public class CodahaleGraphiteSink
extends org.apache.spark.metrics.sink.GraphiteSink

A Spark Sink that is tailored to report AggregatorMetric metrics to Graphite.

Constructor Summary

Constructors

Constructor and Description
CodahaleGraphiteSink(java.util.Properties properties, com.codahale.metrics.MetricRegistry metricRegistry, org.apache.spark.SecurityManager securityMgr)

Method Summary

Methods inherited from class org.apache.spark.metrics.sink.GraphiteSink

GRAPHITE_DEFAULT_PERIOD, GRAPHITE_DEFAULT_PREFIX, GRAPHITE_DEFAULT_UNIT, GRAPHITE_KEY_HOST, GRAPHITE_KEY_PERIOD, GRAPHITE_KEY_PORT, GRAPHITE_KEY_PREFIX, GRAPHITE_KEY_PROTOCOL, GRAPHITE_KEY_UNIT, graphite, host, pollPeriod, pollUnit, port, prefix, property, propertyToOption, registry, report, reporter, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CodahaleGraphiteSink

public CodahaleGraphiteSink(java.util.Properties properties,
                            com.codahale.metrics.MetricRegistry metricRegistry,
                            org.apache.spark.SecurityManager securityMgr)