spark-metrics-Sink.adoc

Sink — Contract of Metrics Sinks

Sink is a contract of metrics sinks.

package org.apache.spark.metrics.sink

trait Sink {
  def start(): Unit
  def stop(): Unit
  def report(): Unit
}

Note	Sink is a private[spark] contract.

Table 1. Sink Contract

Method	Description
start	Used when…​FIXME
stop	Used when…​FIXME
report	Used when…​FIXME

Table 2. Sinks

Sink	Description
ConsoleSink
CsvSink
GraphiteSink
JmxSink
MetricsServlet
Slf4jSink
StatsdSink

Note	All known Sinks in Spark 2.3 are in org.apache.spark.metrics.sink Scala package.