aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorJosh Rosen <rosenville@gmail.com>2013-02-09 15:54:48 -0800
committerJosh Rosen <rosenville@gmail.com>2013-02-09 15:54:48 -0800
commitfc5b2e8b83324db16e6c22dcad9ace5e25983768 (patch)
tree59de2a43003455d37f8ac3b7639edde817bacf44 /python
parent51db4c1f307bc91e4d8a80707fa27b4b7a031b10 (diff)
parentb7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f (diff)
downloadspark-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.
Diffstat (limited to 'python')
-rw-r--r--python/pyspark/rdd.py4
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)