Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

SPARK-1164 Deprecated reduceByKeyToDriver as it is an alias for reduc…

…eByKeyLocally
  • Loading branch information...
commit ee521cd1809d36216e4392880163e75e5aed5150 1 parent 181ec50
@ScrapCodes ScrapCodes authored
View
1  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. */
Please sign in to comment.
Something went wrong with that request. Please try again.