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

Class CodahaleCsvSink

java.lang.Object

org.apache.spark.metrics.sink.CsvSink

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

All Implemented Interfaces:

org.apache.spark.metrics.sink.Sink

public class CodahaleCsvSink
extends org.apache.spark.metrics.sink.CsvSink

A Spark Sink that is tailored to report AggregatorMetric metrics to a CSV file.

Constructor Summary

Constructors

Constructor and Description
CodahaleCsvSink(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.CsvSink

CSV_DEFAULT_DIR, CSV_DEFAULT_PERIOD, CSV_DEFAULT_UNIT, CSV_KEY_DIR, CSV_KEY_PERIOD, CSV_KEY_UNIT, pollDir, pollPeriod, pollUnit, property, 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

CodahaleCsvSink

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