diff options
| author | Mark Hamstra <markhamstra@gmail.com> | 2013-02-09 12:14:11 -0800 |
|---|---|---|
| committer | Mark Hamstra <markhamstra@gmail.com> | 2013-02-09 12:14:11 -0800 |
| commit | b7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f (patch) | |
| tree | 59de2a43003455d37f8ac3b7639edde817bacf44 /python/pyspark | |
| parent | 51db4c1f307bc91e4d8a80707fa27b4b7a031b10 (diff) | |
| download | spark-b7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f.tar.gz spark-b7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f.tar.bz2 spark-b7a1fb5c5dfe12d18fe9c4b1da1818a143cd247f.zip | |
Add commutative requirement for 'reduce' to Python docstring.
Diffstat (limited to 'python/pyspark')
| -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) |