org.apache.spark.ui

Class JettyUtils

Object

org.apache.spark.ui.JettyUtils

All Implemented Interfaces:

Logging

public class JettyUtils
extends Object
implements Logging

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

Methods

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	createRedirectHandler(String srcPath, String destPath, scala.Function1<javax.servlet.http.HttpServletRequest,scala.runtime.BoxedUnit> beforeRedirect, String basePath) Create a handler that always redirects the user to the given path
static <T> javax.servlet.http.HttpServlet	createServlet(JettyUtils.ServletParams<T> servletParams, SecurityManager securityMgr, 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, SecurityManager securityMgr, 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 ServerInfo	startJettyServer(String hostName, int port, 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)

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

Constructor Detail

JettyUtils

public JettyUtils()

Method Detail

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,
                                               SecurityManager securityMgr,
                                               scala.Function1<T,Object> evidence$2)

createServletHandler

public static <T> org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(String path,
                                                                       JettyUtils.ServletParams<T> servletParams,
                                                                       SecurityManager securityMgr,
                                                                       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)

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

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 ServerInfo startJettyServer(String hostName,
                          int port,
                          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.