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 and Description
static class	JettyUtils.ServletParams<T>
static class	JettyUtils.ServletParams$

Constructor Summary

Constructors

Constructor and Description
JettyUtils()

Method Summary

Modifier and Type	Method and Description
static void	addFilters(scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers, SparkConf conf) Add filters, if any, to the given list of ServletContextHandlers
static org.eclipse.jetty.servlet.ServletContextHandler	createProxyHandler(String prefix, String target) Create a handler for proxying request to Workers and Application Drivers
static String	createProxyLocationHeader(String prefix, String headerValue, javax.servlet.http.HttpServletRequest clientRequest, java.net.URI targetUri)
static java.net.URI	createProxyURI(String prefix, String target, String path, String query)
static org.eclipse.jetty.servlet.ServletContextHandler	createRedirectHandler(String srcPath, String destPath, scala.Function1<javax.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 <T> javax.servlet.http.HttpServlet	createServlet(JettyUtils.ServletParams<T> servletParams, org.apache.spark.SecurityManager securityMgr, SparkConf conf, scala.Function1<T,Object> evidence$2)
static org.eclipse.jetty.servlet.ServletContextHandler	createServletHandler(String path, javax.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, org.apache.spark.SecurityManager securityMgr, SparkConf conf, String basePath, scala.Function1<T,Object> evidence$3) 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.Seq<scala.xml.Node>>	htmlResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,scala.collection.Seq<scala.xml.Node>> responder)
static JettyUtils.ServletParams<org.json4s.JsonAST.JValue>	jsonResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,org.json4s.JsonAST.JValue> responder)
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, scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers, SparkConf conf, String serverName) Attempt to start a Jetty server bound to the supplied hostName:port using the given context handlers.
static JettyUtils.ServletParams<String>	textResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,String> responder)
static String[]	toVirtualHosts(scala.collection.Seq<String> connectors)

Methods inherited from class Object

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

Constructor Detail

JettyUtils

public JettyUtils()

Method Detail

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.JsonAST.JValue> jsonResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,org.json4s.JsonAST.JValue> responder)

htmlResponderToServlet

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

textResponderToServlet

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

createServlet

public static <T> javax.servlet.http.HttpServlet createServlet(JettyUtils.ServletParams<T> servletParams,
                                                               org.apache.spark.SecurityManager securityMgr,
                                                               SparkConf conf,
                                                               scala.Function1<T,Object> evidence$2)

createServletHandler

public static <T> org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(String path,
                                                                                       JettyUtils.ServletParams<T> servletParams,
                                                                                       org.apache.spark.SecurityManager securityMgr,
                                                                                       SparkConf conf,
                                                                                       String basePath,
                                                                                       scala.Function1<T,Object> evidence$3)

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,
                                                                                   javax.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<javax.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(String prefix,
                                                                                 String target)

Create a handler for proxying request to Workers and Application Drivers

addFilters

public static void addFilters(scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers,
                              SparkConf conf)

Add filters, if any, to the given list of ServletContextHandlers

startJettyServer

public static org.apache.spark.ui.ServerInfo startJettyServer(String hostName,
                                                              int port,
                                                              org.apache.spark.SSLOptions sslOptions,
                                                              scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers,
                                                              SparkConf conf,
                                                              String serverName)

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)

handlers - (undocumented)

conf - (undocumented)

serverName - (undocumented)

Returns:

(undocumented)

createProxyURI

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

createProxyLocationHeader

public static String createProxyLocationHeader(String prefix,
                                               String headerValue,
                                               javax.servlet.http.HttpServletRequest clientRequest,
                                               java.net.URI targetUri)

toVirtualHosts

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