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

Spark sinks that supports beam metrics and aggregators.

See: Description

Class Summary

Class	Description
CodahaleCsvSink	A Spark Sink that is tailored to report AggregatorMetric metrics to a CSV file.
CodahaleGraphiteSink	A Spark Sink that is tailored to report AggregatorMetric metrics to Graphite.

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

Spark sinks that supports beam metrics and aggregators.