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
  • 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)