Skip to content

Commit ad7e374

Browse files
committed
fix tests
1 parent 2f63512 commit ad7e374

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

python/pyspark/rdd.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -822,6 +822,8 @@ def max(self, key=None):
822822
>>> rdd.max(key=str)
823823
5.0
824824
"""
825+
if key is None:
826+
return self.reduce(max)
825827
return self.reduce(lambda a, b: max(a, b, key=key))
826828

827829
def min(self, key=None):
@@ -836,6 +838,8 @@ def min(self, key=None):
836838
>>> rdd.min(key=str)
837839
10.0
838840
"""
841+
if key is None:
842+
return self.reduce(min)
839843
return self.reduce(lambda a, b: min(a, b, key=key))
840844

841845
def sum(self):

0 commit comments

Comments
 (0)