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.

results matching ""

    No results matching ""