Browse Source

[livy] Use Seq instead of List

Erick Tryzelaar 10 years ago
parent
commit
aec6f9a

+ 1 - 1
apps/spark/java/livy-core/src/main/scala/com/cloudera/hue/livy/ExecuteResponse.scala

@@ -1,6 +1,6 @@
 package com.cloudera.hue.livy
 
-case class ExecuteResponse(id: Int /*, state: State*/, input: List[String], output: List[String])
+case class ExecuteResponse(id: Int /*, state: State*/, input: Seq[String], output: Seq[String])
 
 sealed trait State
 case class Ready() extends State

+ 1 - 1
apps/spark/java/livy-repl/src/main/scala/com/cloudera/hue/livy/repl/Session.scala

@@ -5,7 +5,7 @@ import com.cloudera.hue.livy.ExecuteResponse
 import scala.concurrent.Future
 
 trait Session {
-  def statements: List[ExecuteResponse]
+  def statements: Seq[ExecuteResponse]
 
   def statement(id: Int): Option[ExecuteResponse]
 

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

@@ -3,7 +3,7 @@ package com.cloudera.hue.livy.server
 import scala.concurrent.{ExecutionContext, ExecutionContextExecutor, Future}
 import scala.util.{Failure, Success}
 
-class Statement(val id: Int, val input: String, val output: Future[List[String]]) {
+class Statement(val id: Int, val input: String, val output: Future[Seq[String]]) {
   sealed trait State
   case class Running() extends State
   case class Available() extends State

+ 4 - 4
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/sessions/SparkWebSession.scala

@@ -60,15 +60,15 @@ abstract class SparkWebSession(val id: String, hostname: String, port: Int) exte
     }
   }
 
-  override def statements(): List[Statement] = {
+  override def statements(): Seq[Statement] = {
     ensureRunning {
-      statements_.toList
+      statements_.toSeq
     }
   }
 
-  override def statements(fromIndex: Integer, toIndex: Integer): List[Statement] = {
+  override def statements(fromIndex: Integer, toIndex: Integer): Seq[Statement] = {
     ensureRunning {
-      statements_.slice(fromIndex, toIndex).toList
+      statements_.slice(fromIndex, toIndex).toSeq
     }
   }
 

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

@@ -16,9 +16,9 @@ trait Session {
 
   def statement(statementId: Int): Option[Statement]
 
-  def statements(): List[Statement]
+  def statements(): Seq[Statement]
 
-  def statements(fromIndex: Integer, toIndex: Integer): List[Statement]
+  def statements(fromIndex: Integer, toIndex: Integer): Seq[Statement]
 
   def interrupt(): Future[Unit]