You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/07/09 00:18:27 UTC

spark git commit: [SPARK-8908] [SQL] Add () to distinct definition in dataframe

Repository: spark
Updated Branches:
  refs/heads/master 8f3cd9327 -> 00b265f12


[SPARK-8908] [SQL] Add () to distinct definition in dataframe

Adding `()` to the definition of `distinct` in DataFrame allows distinct to be called with parentheses, which is consistent with `dropDuplicates`.

Author: Cheolsoo Park <ch...@netflix.com>

Closes #7298 from piaozhexiu/SPARK-8908 and squashes the following commits:

7f0d923 [Cheolsoo Park] Add () to distinct definition in dataframe


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/00b265f1
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/00b265f1
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/00b265f1

Branch: refs/heads/master
Commit: 00b265f12c0f0271b7036f831fee09b694908b29
Parents: 8f3cd93
Author: Cheolsoo Park <ch...@netflix.com>
Authored: Wed Jul 8 15:18:24 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Wed Jul 8 15:18:24 2015 -0700

----------------------------------------------------------------------
 sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/00b265f1/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
----------------------------------------------------------------------
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 6014229..f33e19a 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
@@ -1415,7 +1415,7 @@ class DataFrame private[sql](
    * @group dfops
    * @since 1.3.0
    */
-  override def distinct: DataFrame = dropDuplicates()
+  override def distinct(): DataFrame = dropDuplicates()
 
   /**
    * @group basic


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org