spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject git commit: SPARK-1164 Deprecated reduceByKeyToDriver as it is an alias for reduceByKeyLocally
Date Tue, 04 Mar 2014 18:27:04 GMT
Repository: spark
Updated Branches:
  refs/heads/master 181ec5030 -> 2d8e0a062


SPARK-1164 Deprecated reduceByKeyToDriver as it is an alias for reduceByKeyLocally

Author: Prashant Sharma <prashant.s@imaginea.com>

Closes #72 from ScrapCodes/SPARK-1164/deprecate-reducebykeytodriver and squashes the following
commits:

ee521cd [Prashant Sharma] SPARK-1164 Deprecated reduceByKeyToDriver as it is an alias for
reduceByKeyLocally


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

Branch: refs/heads/master
Commit: 2d8e0a062cef878bcc878e4825a5771d35f0509f
Parents: 181ec50
Author: Prashant Sharma <prashant.s@imaginea.com>
Authored: Tue Mar 4 10:27:02 2014 -0800
Committer: Reynold Xin <rxin@apache.org>
Committed: Tue Mar 4 10:27:02 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/2d8e0a06/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala b/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
index 5aa0b03..2384c8f 100644
--- a/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
+++ b/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
@@ -193,6 +193,7 @@ class PairRDDFunctions[K: ClassTag, V: ClassTag](self: RDD[(K, V)])
   }
 
   /** Alias for reduceByKeyLocally */
+  @deprecated("Use reduceByKeyLocally", "1.0.0")
   def reduceByKeyToDriver(func: (V, V) => V): Map[K, V] = reduceByKeyLocally(func)
 
   /** Count the number of elements for each key, and return the result to the master as a
Map. */


Mime
View raw message