diff options
| author | Reynold Xin <rxin@databricks.com> | 2015-02-02 16:55:36 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-02-02 16:55:36 -0800 |
| commit | 8aa3cfff661753d6d87a8d9a87373d403436dd92 (patch) | |
| tree | c9fd1b9ae223b26756bd7652b947e5e940f576a1 /sql | |
| parent | dca6faa29a8dd805cf364ed2683efaf7928f2112 (diff) | |
| download | spark-8aa3cfff661753d6d87a8d9a87373d403436dd92.tar.gz spark-8aa3cfff661753d6d87a8d9a87373d403436dd92.tar.bz2 spark-8aa3cfff661753d6d87a8d9a87373d403436dd92.zip | |
[SPARK-5514] DataFrame.collect should call executeCollect
Author: Reynold Xin <rxin@databricks.com>
Closes #4313 from rxin/SPARK-5514 and squashes the following commits:
e34e91b [Reynold Xin] [SPARK-5514] DataFrame.collect should call executeCollect
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 2 |
1 files changed, 1 insertions, 1 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 1096e39659..5d42d4428d 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 @@ -541,7 +541,7 @@ class DataFrame protected[sql]( /** * Returns an array that contains all of [[Row]]s in this [[DataFrame]]. */ - override def collect(): Array[Row] = rdd.collect() + override def collect(): Array[Row] = queryExecution.executedPlan.executeCollect() /** * Returns a Java list that contains all of [[Row]]s in this [[DataFrame]]. |