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

ScrapCodes · rxin · commit 2d8e0a062cef · 2014-03-04T10:27:02.000-08:00
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
diff --git 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. */

Original file line number	Diff line number	Diff line change
`@@ -193,6 +193,7 @@ class PairRDDFunctions[K: ClassTag, V: ClassTag](self: RDD[(K, V)])`
`193`	`193`	`}`
`194`	`194`
`195`	`195`	`/** Alias for reduceByKeyLocally */`
	`196`	`+ @deprecated("Use reduceByKeyLocally", "1.0.0")`
`196`	`197`	`def reduceByKeyToDriver(func: (V, V) => V): Map[K, V] = reduceByKeyLocally(func)`
`197`	`198`
`198`	`199`	`/** Count the number of elements for each key, and return the result to the master as a Map. */`