org.apache.spark.ui

Class SparkUI

Object

org.apache.spark.ui.WebUI

org.apache.spark.ui.SparkUI

All Implemented Interfaces:

Logging

public class SparkUI
extends WebUI
implements Logging

Top level user interface for a Spark application.

Method Summary

Methods

Modifier and Type	Method and Description
String	appName()
String	appUIAddress()
String	appUIHostPort() Return the application UI host:port.
String	basePath()
SparkConf	conf()
static SparkUI	createHistoryUI(SparkConf conf, SparkListenerBus listenerBus, SecurityManager securityManager, String appName, String basePath)
static SparkUI	createLiveUI(SparkContext sc, SparkConf conf, SparkListenerBus listenerBus, JobProgressListener jobProgressListener, SecurityManager securityManager, String appName)
static int	DEFAULT_PORT()
EnvironmentListener	environmentListener()
ExecutorsListener	executorsListener()
String	getAppName()
static int	getUIPort(SparkConf conf)
void	initialize() Initialize all components of the server.
JobProgressListener	jobProgressListener()
boolean	killEnabled()
scala.Option<SparkContext>	sc()
SecurityManager	securityManager()
void	setAppName(String name) Set the app name for this UI.
static String	STATIC_RESOURCE_DIR()
void	stop() Stop the server behind this web interface.
StorageListener	storageListener()
StorageStatusListener	storageStatusListener()

Methods inherited from class org.apache.spark.ui.WebUI

attachHandler, attachPage, attachTab, bind, boundPort, getBasePath, getHandlers, getSecurityManager, getTabs

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Method Detail

DEFAULT_PORT

public static int DEFAULT_PORT()

STATIC_RESOURCE_DIR

public static String STATIC_RESOURCE_DIR()

getUIPort

public static int getUIPort(SparkConf conf)

createLiveUI

public static SparkUI createLiveUI(SparkContext sc,
                   SparkConf conf,
                   SparkListenerBus listenerBus,
                   JobProgressListener jobProgressListener,
                   SecurityManager securityManager,
                   String appName)

createHistoryUI

public static SparkUI createHistoryUI(SparkConf conf,
                      SparkListenerBus listenerBus,
                      SecurityManager securityManager,
                      String appName,
                      String basePath)

sc

public scala.Option<SparkContext> sc()

conf

public SparkConf conf()

securityManager

public SecurityManager securityManager()

environmentListener

public EnvironmentListener environmentListener()

storageStatusListener

public StorageStatusListener storageStatusListener()

executorsListener

public ExecutorsListener executorsListener()

jobProgressListener

public JobProgressListener jobProgressListener()

storageListener

public StorageListener storageListener()

appName

public String appName()

basePath

public String basePath()

killEnabled

public boolean killEnabled()

initialize

public void initialize()

Initialize all components of the server.

Specified by:

initialize in class WebUI

getAppName

public String getAppName()

setAppName

public void setAppName(String name)

Set the app name for this UI.

stop

public void stop()

Stop the server behind this web interface. Only valid after bind().

Overrides:

stop in class WebUI

appUIHostPort

public String appUIHostPort()

Return the application UI host:port. This does not include the scheme (http://).

appUIAddress

public String appUIAddress()