Make all output one Row.

xiliu82 · Jun 7, 2014 · 4318fd7 · 4318fd7
1 parent 439c6ab
commit 4318fd7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/commands.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/commands.scala
@@ -24,8 +24,8 @@ import org.apache.spark.sql.catalyst.expressions.{GenericRow, Attribute}
 case class ExplainCommandPhysical(child: SparkPlan)
                                  (@transient context: SQLContext) extends UnaryNode {
   def execute(): RDD[Row] = {
-    val lines = child.toString.split("\n").map(s => new GenericRow(Array[Any](s)))
-    context.sparkContext.parallelize(lines)
+    val planString = new GenericRow(Array[Any](child.toString))
+    context.sparkContext.parallelize(Seq(planString))
   }
 
   def output: Seq[Attribute] = child.output // right thing to do?