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
}
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

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