From f3b727c801408b1cd50e5d9463f2fe0fce654a16 Mon Sep 17 00:00:00 2001
From: Reynold Xin <rxin@databricks.com>
Date: Tue, 22 Sep 2015 00:09:29 -0700
Subject: [PATCH] [SQL] [MINOR] map -> foreach.
DataFrame.explain should use foreach to print the explain content.
Author: Reynold Xin <rxin@databricks.com>
Closes #8862 from rxin/map-foreach.
---
sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 5 ++---
1 file changed, 2 insertions(+), 3 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 ba94d77b2e..a11140b717 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
@@ -320,9 +320,8 @@ class DataFrame private[sql](
* @since 1.3.0
*/
def explain(extended: Boolean): Unit = {
- ExplainCommand(
- queryExecution.logical,
- extended = extended).queryExecution.executedPlan.executeCollect().map {
+ val explain = ExplainCommand(queryExecution.logical, extended = extended)
+ explain.queryExecution.executedPlan.executeCollect().foreach {
// scalastyle:off println
r => println(r.getString(0))
// scalastyle:on println
--
GitLab