Package org.apache.spark.ui

Class JettyUtils

Object

org.apache.spark.ui.JettyUtils

public class JettyUtils
extends Object

Utilities for launching a web server using Jetty's HTTP Server class

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JettyUtils.ServletParams<T>
static class	JettyUtils.ServletParams$

Constructor Summary

Constructors

Constructor	Description
JettyUtils()

Method Summary

Modifier and Type	Method	Description
static void	addFilter(org.eclipse.jetty.servlet.ServletContextHandler handler, String filter, scala.collection.immutable.Map<String,String> params)
static org.eclipse.jetty.servlet.ServletContextHandler	createProxyHandler(scala.Function1<String,scala.Option<String>> idToUiAddress)	Create a handler for proxying request to Workers and Application Drivers
static String	createProxyLocationHeader(String headerValue, jakarta.servlet.http.HttpServletRequest clientRequest, URI targetUri)
static URI	createProxyURI(String prefix, String target, String path, String query)
static org.eclipse.jetty.servlet.ServletContextHandler	createRedirectHandler(String srcPath, String destPath, scala.Function1<jakarta.servlet.http.HttpServletRequest,scala.runtime.BoxedUnit> beforeRedirect, String basePath, scala.collection.immutable.Set<String> httpMethods)	Create a handler that always redirects the user to the given path
static org.eclipse.jetty.servlet.ServletContextHandler	createServletHandler(String path, jakarta.servlet.http.HttpServlet servlet, String basePath)	Create a context handler that responds to a request with the given path prefix
static <T> org.eclipse.jetty.servlet.ServletContextHandler	createServletHandler(String path, JettyUtils.ServletParams<T> servletParams, SparkConf conf, String basePath)	Create a context handler that responds to a request with the given path prefix
static org.eclipse.jetty.servlet.ServletContextHandler	createStaticHandler(String resourceBase, String path)	Create a handler for serving files from a static directory
static JettyUtils.ServletParams<scala.collection.immutable.Seq<scala.xml.Node>>	htmlResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,scala.collection.immutable.Seq<scala.xml.Node>> responder)
static JettyUtils.ServletParams<org.json4s.JValue>	jsonResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,org.json4s.JValue> responder)
static org.apache.spark.internal.Logging.LogStringContext	LogStringContext(scala.StringContext sc)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static String	REDIRECT_CONNECTOR_NAME()
static String	SPARK_CONNECTOR_NAME()
static org.apache.spark.ui.ServerInfo	startJettyServer(String hostName, int port, org.apache.spark.SSLOptions sslOptions, SparkConf conf, String serverName, int poolSize)	Attempt to start a Jetty server bound to the supplied hostName:port using the given context handlers.
static JettyUtils.ServletParams<String>	textResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,String> responder)
static String[]	toVirtualHosts(scala.collection.immutable.Seq<String> connectors)

Methods inherited from class java.lang.Object

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

Constructor Details

JettyUtils

public JettyUtils()

Method Details

SPARK_CONNECTOR_NAME

public static String SPARK_CONNECTOR_NAME()

REDIRECT_CONNECTOR_NAME

public static String REDIRECT_CONNECTOR_NAME()

jsonResponderToServlet

public static JettyUtils.ServletParams<org.json4s.JValue> jsonResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,org.json4s.JValue> responder)

htmlResponderToServlet

public static JettyUtils.ServletParams<scala.collection.immutable.Seq<scala.xml.Node>> htmlResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,scala.collection.immutable.Seq<scala.xml.Node>> responder)

textResponderToServlet

public static JettyUtils.ServletParams<String> textResponderToServlet(scala.Function1<jakarta.servlet.http.HttpServletRequest,String> responder)

createServletHandler

public static <T>
org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(String path,
 JettyUtils.ServletParams<T> servletParams,
 SparkConf conf,
 String basePath)

Create a context handler that responds to a request with the given path prefix

createServletHandler

public static org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(String path,
 jakarta.servlet.http.HttpServlet servlet,
 String basePath)

Create a context handler that responds to a request with the given path prefix

createRedirectHandler

public static org.eclipse.jetty.servlet.ServletContextHandler createRedirectHandler(String srcPath,
 String destPath,
 scala.Function1<jakarta.servlet.http.HttpServletRequest,scala.runtime.BoxedUnit> beforeRedirect,
 String basePath,
 scala.collection.immutable.Set<String> httpMethods)

Create a handler that always redirects the user to the given path

createStaticHandler

public static org.eclipse.jetty.servlet.ServletContextHandler createStaticHandler(String resourceBase,
 String path)

Create a handler for serving files from a static directory

createProxyHandler

public static org.eclipse.jetty.servlet.ServletContextHandler createProxyHandler(scala.Function1<String,scala.Option<String>> idToUiAddress)

Create a handler for proxying request to Workers and Application Drivers

startJettyServer

public static org.apache.spark.ui.ServerInfo startJettyServer(String hostName,
 int port,
 org.apache.spark.SSLOptions sslOptions,
 SparkConf conf,
 String serverName,
 int poolSize)

Attempt to start a Jetty server bound to the supplied hostName:port using the given context handlers.

If the desired port number is contended, continues incrementing ports until a free port is found. Return the jetty Server object, the chosen port, and a mutable collection of handlers.

Parameters:

hostName - (undocumented)

port - (undocumented)

sslOptions - (undocumented)

conf - (undocumented)

serverName - (undocumented)

poolSize - (undocumented)

Returns:

(undocumented)

createProxyURI

public static URI createProxyURI(String prefix,
 String target,
 String path,
 String query)

createProxyLocationHeader

public static String createProxyLocationHeader(String headerValue,
 jakarta.servlet.http.HttpServletRequest clientRequest,
 URI targetUri)

addFilter

public static void addFilter(org.eclipse.jetty.servlet.ServletContextHandler handler,
 String filter,
 scala.collection.immutable.Map<String,String> params)

toVirtualHosts

public static String[] toVirtualHosts(scala.collection.immutable.Seq<String> connectors)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

LogStringContext

public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)