瀏覽代碼

[livy] Import cleanup

Erick Tryzelaar 10 年之前
父節點
當前提交
4bd9193d01

+ 0 - 2
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/SessionFactory.scala

@@ -20,8 +20,6 @@ package com.cloudera.hue.livy.server
 
 import org.json4s.{DefaultFormats, Formats, JValue}
 
-import scala.concurrent.Future
-
 abstract class SessionFactory[S <: Session] {
 
   protected implicit def jsonFormats: Formats = DefaultFormats

+ 2 - 2
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/SessionServlet.scala

@@ -22,11 +22,11 @@ import com.cloudera.hue.livy.Logging
 import com.cloudera.hue.livy.server.interactive.InteractiveSession.SessionFailedToStart
 import com.fasterxml.jackson.core.JsonParseException
 import org.json4s.JsonDSL._
-import org.json4s.{MappingException, DefaultFormats, Formats, JValue}
+import org.json4s.{DefaultFormats, Formats, JValue, MappingException}
 import org.scalatra._
 import org.scalatra.json.JacksonJsonSupport
 
-import scala.concurrent.{Future, ExecutionContext}
+import scala.concurrent.{ExecutionContext, Future}
 
 object SessionServlet extends Logging
 

+ 0 - 2
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/batch/BatchSessionFactory.scala

@@ -21,8 +21,6 @@ package com.cloudera.hue.livy.server.batch
 import com.cloudera.hue.livy.server.SessionFactory
 import org.json4s.JValue
 
-import scala.concurrent.Future
-
 abstract class BatchSessionFactory extends SessionFactory[BatchSession] {
   override def create(id: Int, createRequest: JValue) =
     create(id, createRequest.extract[CreateBatchRequest])

+ 1 - 1
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/batch/BatchSessionServlet.scala

@@ -20,6 +20,7 @@ package com.cloudera.hue.livy.server.batch
 
 import com.cloudera.hue.livy.Logging
 import com.cloudera.hue.livy.server.{SessionManager, SessionServlet}
+import org.json4s.JsonDSL._
 import org.json4s._
 
 import scala.concurrent.{ExecutionContext, ExecutionContextExecutor}
@@ -37,7 +38,6 @@ class BatchSessionServlet(batchManager: SessionManager[BatchSession])
 }
 
 private object Serializers {
-  import org.json4s.JsonDSL._
 
   def Formats: List[CustomSerializer[_]] = List(BatchSerializer)
 

+ 0 - 2
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/batch/BatchSessionYarnFactory.scala

@@ -21,8 +21,6 @@ package com.cloudera.hue.livy.server.batch
 import com.cloudera.hue.livy.LivyConf
 import com.cloudera.hue.livy.yarn.Client
 
-import scala.concurrent.Future
-
 class BatchSessionYarnFactory(livyConf: LivyConf) extends BatchSessionFactory {
 
   val client = new Client(livyConf)

+ 0 - 3
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/interactive/InteractiveSessionServlet.scala

@@ -24,11 +24,8 @@ import java.util.concurrent.TimeUnit
 import com.cloudera.hue.livy.Logging
 import com.cloudera.hue.livy.msgs.ExecuteRequest
 import com.cloudera.hue.livy.server.{SessionManager, SessionServlet}
-import com.cloudera.hue.livy.server.interactive.InteractiveSession.SessionFailedToStart
 import com.cloudera.hue.livy.sessions._
-import com.fasterxml.jackson.core.JsonParseException
 import org.json4s.JsonAST.JString
-import org.json4s.JsonDSL._
 import org.json4s._
 import org.scalatra._