AppStatusPlugin — Contract for

AppStatusPlugin is the contract for…​FIXME

package org.apache.spark.status

trait AppStatusPlugin {
  def setupListeners(
    conf: SparkConf,
    store: KVStore,
    addListenerFn: SparkListener => Unit,
    live: Boolean): Unit

  def setupUI(ui: SparkUI): Unit
}
Note
AppStatusPlugin is a private[spark] Scala trait.
Table 1. AppStatusPlugin Contract
Method Description

setupListeners

setupUI

loadPlugins Method

loadPlugins(): Iterable[AppStatusPlugin]

loadPlugins…​FIXME

Note

loadPlugins is used when:

  1. SparkContext is created (and creates a web UI)

  2. FsHistoryProvider creates a web UI

  3. AppStatusStore creates an in-memory store for a live Spark application

results matching ""

    No results matching ""