From 096b1e89eb89540d03f48ceb98d9b055252da2e9 Mon Sep 17 00:00:00 2001 From: scwf Date: Tue, 26 May 2015 19:43:13 +0800 Subject: [PATCH] improve dataframe explain --- .../main/scala/org/apache/spark/sql/DataFrame.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala index f968577bc5848..94405015abba9 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala @@ -294,11 +294,11 @@ class DataFrame private[sql]( * @since 1.3.0 */ def explain(extended: Boolean): Unit = { - ExplainCommand( - queryExecution.logical, - extended = extended).queryExecution.executedPlan.executeCollect().map { - r => println(r.getString(0)) - } + println( + ExplainCommand( + queryExecution.logical, + extended = extended).queryExecution.toString + ) } /**