public class JettyUtils
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
JettyUtils.ServletParams<T> |
static class |
JettyUtils.ServletParams$ |
Constructor and Description |
---|
JettyUtils() |
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(java.lang.String srcPath,
java.lang.String destPath,
scala.Function1<javax.servlet.http.HttpServletRequest,scala.runtime.BoxedUnit> beforeRedirect,
java.lang.String basePath,
scala.collection.immutable.Set<java.lang.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,java.lang.Object> evidence$2) |
static org.eclipse.jetty.servlet.ServletContextHandler |
createServletHandler(java.lang.String path,
javax.servlet.http.HttpServlet servlet,
java.lang.String basePath)
Create a context handler that responds to a request with the given path prefix
|
static <T> org.eclipse.jetty.servlet.ServletContextHandler |
createServletHandler(java.lang.String path,
JettyUtils.ServletParams<T> servletParams,
org.apache.spark.SecurityManager securityMgr,
SparkConf conf,
java.lang.String basePath,
scala.Function1<T,java.lang.Object> evidence$3)
Create a context handler that responds to a request with the given path prefix
|
static org.eclipse.jetty.servlet.ServletContextHandler |
createStaticHandler(java.lang.String resourceBase,
java.lang.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) |
protected static void |
initializeLogIfNecessary(boolean isInterpreter) |
protected static boolean |
isTraceEnabled() |
static JettyUtils.ServletParams<org.json4s.JsonAST.JValue> |
jsonResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,org.json4s.JsonAST.JValue> responder) |
protected static org.slf4j.Logger |
log() |
protected static void |
logDebug(scala.Function0<java.lang.String> msg) |
protected static void |
logDebug(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logError(scala.Function0<java.lang.String> msg) |
protected static void |
logError(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static java.lang.String |
logName() |
protected static void |
logTrace(scala.Function0<java.lang.String> msg) |
protected static void |
logTrace(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
static org.apache.spark.ui.ServerInfo |
startJettyServer(java.lang.String hostName,
int port,
org.apache.spark.SSLOptions sslOptions,
scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers,
SparkConf conf,
java.lang.String serverName)
Attempt to start a Jetty server bound to the supplied hostName:port using the given
context handlers.
|
static JettyUtils.ServletParams<java.lang.String> |
textResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,java.lang.String> responder) |
public static JettyUtils.ServletParams<org.json4s.JsonAST.JValue> jsonResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,org.json4s.JsonAST.JValue> responder)
public static JettyUtils.ServletParams<scala.collection.Seq<scala.xml.Node>> htmlResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,scala.collection.Seq<scala.xml.Node>> responder)
public static JettyUtils.ServletParams<java.lang.String> textResponderToServlet(scala.Function1<javax.servlet.http.HttpServletRequest,java.lang.String> responder)
public static <T> javax.servlet.http.HttpServlet createServlet(JettyUtils.ServletParams<T> servletParams, org.apache.spark.SecurityManager securityMgr, SparkConf conf, scala.Function1<T,java.lang.Object> evidence$2)
public static <T> org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(java.lang.String path, JettyUtils.ServletParams<T> servletParams, org.apache.spark.SecurityManager securityMgr, SparkConf conf, java.lang.String basePath, scala.Function1<T,java.lang.Object> evidence$3)
public static org.eclipse.jetty.servlet.ServletContextHandler createServletHandler(java.lang.String path, javax.servlet.http.HttpServlet servlet, java.lang.String basePath)
public static org.eclipse.jetty.servlet.ServletContextHandler createRedirectHandler(java.lang.String srcPath, java.lang.String destPath, scala.Function1<javax.servlet.http.HttpServletRequest,scala.runtime.BoxedUnit> beforeRedirect, java.lang.String basePath, scala.collection.immutable.Set<java.lang.String> httpMethods)
public static org.eclipse.jetty.servlet.ServletContextHandler createStaticHandler(java.lang.String resourceBase, java.lang.String path)
public static void addFilters(scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers, SparkConf conf)
public static org.apache.spark.ui.ServerInfo startJettyServer(java.lang.String hostName, int port, org.apache.spark.SSLOptions sslOptions, scala.collection.Seq<org.eclipse.jetty.servlet.ServletContextHandler> handlers, SparkConf conf, java.lang.String serverName)
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.
hostName
- (undocumented)port
- (undocumented)sslOptions
- (undocumented)handlers
- (undocumented)conf
- (undocumented)serverName
- (undocumented)protected static java.lang.String logName()
protected static org.slf4j.Logger log()
protected static void logInfo(scala.Function0<java.lang.String> msg)
protected static void logDebug(scala.Function0<java.lang.String> msg)
protected static void logTrace(scala.Function0<java.lang.String> msg)
protected static void logWarning(scala.Function0<java.lang.String> msg)
protected static void logError(scala.Function0<java.lang.String> msg)
protected static void logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static boolean isTraceEnabled()
protected static void initializeLogIfNecessary(boolean isInterpreter)