diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 4cda6cf661197f662351bb5f08154b7aae1241f2..6b6ab6abd97e99b8850ac0764ba2c4ebb4cef5d8 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)