aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorCheng Lian <lian.cs.zju@gmail.com>2014-06-16 16:42:17 -0700
committerReynold Xin <rxin@apache.org>2014-06-16 16:42:17 -0700
commit237b96bc59ab1b54c31d06a5260cd77e1eb96116 (patch)
treef2b1140f6557097bf5d5978c4cceb96e0d4b0717 /sql/core
parent273afcb254fb5384204c56bdcb3b9b760bcfab3f (diff)
downloadspark-237b96bc59ab1b54c31d06a5260cd77e1eb96116.tar.gz
spark-237b96bc59ab1b54c31d06a5260cd77e1eb96116.tar.bz2
spark-237b96bc59ab1b54c31d06a5260cd77e1eb96116.zip
Minor fix: made "EXPLAIN" output to play well with JDBC output format
Fixed the broken JDBC output. Test from Shark `beeline`: ``` beeline> !connect jdbc:hive2://localhost:10000/ scan complete in 2ms Connecting to jdbc:hive2://localhost:10000/ Enter username for jdbc:hive2://localhost:10000/: lian Enter password for jdbc:hive2://localhost:10000/: Connected to: Hive (version 0.12.0) Driver: Hive (version 0.12.0) Transaction isolation: TRANSACTION_REPEATABLE_READ 0: jdbc:hive2://localhost:10000/> 0: jdbc:hive2://localhost:10000/> explain select * from src; +-------------------------------------------------------------------------------+ | plan | +-------------------------------------------------------------------------------+ | ExplainCommand [plan#2:0] | | HiveTableScan [key#0,value#1], (MetastoreRelation default, src, None), None | +-------------------------------------------------------------------------------+ 2 rows selected (1.386 seconds) ``` Before this change, the output looked something like this: ``` +-------------------------------------------------------------------------------+ | plan | +-------------------------------------------------------------------------------+ | ExplainCommand [plan#2:0] HiveTableScan [key#0,value#1], (MetastoreRelation default, src, None), None | +-------------------------------------------------------------------------------+ ``` Author: Cheng Lian <lian.cs.zju@gmail.com> Closes #1097 from liancheng/multiLineExplain and squashes the following commits: eb37967 [Cheng Lian] Made output of "EXPLAIN" play well with JDBC output format
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/commands.scala4
1 files changed, 2 insertions, 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
index 0377290af5..39b3246c87 100644
--- 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
@@ -83,8 +83,8 @@ case class ExplainCommand(
override protected[sql] lazy val sideEffectResult: Seq[String] = this.toString.split("\n")
def execute(): RDD[Row] = {
- val explanation = sideEffectResult.mkString("\n")
- context.sparkContext.parallelize(Seq(new GenericRow(Array[Any](explanation))), 1)
+ val explanation = sideEffectResult.map(row => new GenericRow(Array[Any](row)))
+ context.sparkContext.parallelize(explanation, 1)
}
override def otherCopyArgs = context :: Nil