Browse Source

[livy] Allow RDDs to be used with %json magic

Erick Tryzelaar 10 years ago
parent
commit
19be850

+ 7 - 0
apps/spark/java/livy-repl/src/main/scala/com/cloudera/hue/livy/repl/scala/SparkInterpreter/SparkInterpreter.scala

@@ -107,6 +107,13 @@ class SparkInterpreter extends Interpreter {
 
   private def executeJsonMagic(name: String): ExecuteResponse = {
     sparkIMain.valueOfTerm(name) match {
+      case Some(value: RDD) =>
+        ExecuteMagic(
+          executeCount,
+          Extraction.decompose(Map(
+            "application/json" -> value.asInstanceOf[RDD[_]].take(10)
+          ))
+        )
       case Some(value) =>
         ExecuteMagic(
           executeCount,