Skip to content
Snippets Groups Projects
Commit 9a24d1a2 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Using scala in XML imports

parent f91e1c48
No related branches found
No related tags found
No related merge requests found
...@@ -8,13 +8,13 @@ import javax.servlet.http.HttpServletRequest ...@@ -8,13 +8,13 @@ import javax.servlet.http.HttpServletRequest
import net.liftweb.json.JsonAST.JValue import net.liftweb.json.JsonAST.JValue
import scala.xml.Node
import spark.deploy.{RequestWorkerState, JsonProtocol, WorkerState} import spark.deploy.{RequestWorkerState, JsonProtocol, WorkerState}
import spark.deploy.worker.ExecutorRunner import spark.deploy.worker.ExecutorRunner
import spark.Utils import spark.Utils
import spark.ui.UIUtils import spark.ui.UIUtils
import xml.Node
class IndexPage(parent: WorkerWebUI) { class IndexPage(parent: WorkerWebUI) {
val worker = parent.worker val worker = parent.worker
val timeout = parent.timeout val timeout = parent.timeout
......
...@@ -10,11 +10,10 @@ import org.eclipse.jetty.server.{Server, Request, Handler} ...@@ -10,11 +10,10 @@ import org.eclipse.jetty.server.{Server, Request, Handler}
import org.eclipse.jetty.server.handler.{ResourceHandler, HandlerList, ContextHandler, AbstractHandler} import org.eclipse.jetty.server.handler.{ResourceHandler, HandlerList, ContextHandler, AbstractHandler}
import scala.util.{Try, Success, Failure} import scala.util.{Try, Success, Failure}
import scala.xml.Node
import spark.Logging import spark.Logging
import xml.Node
/** Utilities for launching a web server using Jetty's HTTP Server class */ /** Utilities for launching a web server using Jetty's HTTP Server class */
private[spark] object JettyUtils extends Logging { private[spark] object JettyUtils extends Logging {
// Base type for a function that returns something based on an HTTP request. Allows for // Base type for a function that returns something based on an HTTP request. Allows for
......
...@@ -7,13 +7,12 @@ import java.util.Date ...@@ -7,13 +7,12 @@ import java.util.Date
import javax.servlet.http.HttpServletRequest import javax.servlet.http.HttpServletRequest
import scala.Some import scala.Some
import scala.xml.{NodeSeq, Node}
import spark.scheduler.Stage import spark.scheduler.Stage
import spark.ui.UIUtils._ import spark.ui.UIUtils._
import spark.storage.StorageLevel import spark.storage.StorageLevel
import xml.{NodeSeq, Node}
/** Page showing list of all ongoing and recently finished stages */ /** Page showing list of all ongoing and recently finished stages */
class IndexPage(parent: JobProgressUI) { class IndexPage(parent: JobProgressUI) {
val listener = parent.listener val listener = parent.listener
......
...@@ -4,13 +4,13 @@ import java.util.Date ...@@ -4,13 +4,13 @@ import java.util.Date
import javax.servlet.http.HttpServletRequest import javax.servlet.http.HttpServletRequest
import scala.xml.Node
import spark.ui.UIUtils._ import spark.ui.UIUtils._
import spark.util.Distribution import spark.util.Distribution
import spark.scheduler.cluster.TaskInfo import spark.scheduler.cluster.TaskInfo
import spark.executor.TaskMetrics import spark.executor.TaskMetrics
import xml.Node
/** Page showing statistics and task list for a given stage */ /** Page showing statistics and task list for a given stage */
class StagePage(parent: JobProgressUI) { class StagePage(parent: JobProgressUI) {
val listener = parent.listener val listener = parent.listener
......
...@@ -2,12 +2,12 @@ package spark.ui.storage ...@@ -2,12 +2,12 @@ package spark.ui.storage
import javax.servlet.http.HttpServletRequest import javax.servlet.http.HttpServletRequest
import scala.xml.Node
import spark.storage.{RDDInfo, StorageUtils} import spark.storage.{RDDInfo, StorageUtils}
import spark.Utils import spark.Utils
import spark.ui.UIUtils._ import spark.ui.UIUtils._
import xml.Node
/** Page showing list of RDD's currently stored in the cluster */ /** Page showing list of RDD's currently stored in the cluster */
class IndexPage(parent: BlockManagerUI) { class IndexPage(parent: BlockManagerUI) {
val sc = parent.sc val sc = parent.sc
......
...@@ -2,13 +2,13 @@ package spark.ui.storage ...@@ -2,13 +2,13 @@ package spark.ui.storage
import javax.servlet.http.HttpServletRequest import javax.servlet.http.HttpServletRequest
import scala.xml.Node
import spark.storage.{StorageStatus, StorageUtils} import spark.storage.{StorageStatus, StorageUtils}
import spark.ui.UIUtils._ import spark.ui.UIUtils._
import spark.Utils import spark.Utils
import spark.storage.BlockManagerMasterActor.BlockStatus import spark.storage.BlockManagerMasterActor.BlockStatus
import xml.Node
/** Page showing storage details for a given RDD */ /** Page showing storage details for a given RDD */
class RDDPage(parent: BlockManagerUI) { class RDDPage(parent: BlockManagerUI) {
val sc = parent.sc val sc = parent.sc
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment