Sink — Contract of Metrics Sinks

2014-03-25 分类：spark-core 阅读(1240) 评论(0)

Sink is a contract of metrics sinks.



package org.apache.spark.metrics.sink

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

package org.apache.spark.metrics.sink

trait Sink {

def start(): Unit

def stop(): Unit

def report(): Unit

}

Note	`Sink` is a `private[spark]` contract.

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

赞(0) 打赏

关注公众号：spark技术分享