diff options
author | Josh Rosen <rosenville@gmail.com> | 2013-02-09 15:54:48 -0800 |
---|---|---|
committer | Josh Rosen <rosenville@gmail.com> | 2013-02-09 15:54:48 -0800 |
commit | fc5b2e8b83324db16e6c22dcad9ace5e25983768 (patch) | |
tree | 59de2a43003455d37f8ac3b7639edde817bacf44 | |
parent | 51db4c1f307bc91e4d8a80707fa27b4b7a031b10 (diff) | |
parent | b7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f (diff) | |
download | spark-fc5b2e8b83324db16e6c22dcad9ace5e25983768.tar.gz spark-fc5b2e8b83324db16e6c22dcad9ace5e25983768.tar.bz2 spark-fc5b2e8b83324db16e6c22dcad9ace5e25983768.zip |
Merge pull request #457 from markhamstra/commutative
Add commutative requirement for 'reduce' to Python docstring.
-rw-r--r-- | python/pyspark/rdd.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 4cda6cf661..6b6ab6abd9 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -274,8 +274,8 @@ class RDD(object): def reduce(self, f): """ - Reduces the elements of this RDD using the specified associative binary - operator. + Reduces the elements of this RDD using the specified commutative and + associative binary operator. >>> from operator import add >>> sc.parallelize([1, 2, 3, 4, 5]).reduce(add) |