Skip to content

Commit fbed000

Browse files
test the absolute error in approx doctests
1 parent 50d3242 commit fbed000

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/rdd.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2198,7 +2198,7 @@ def sumApprox(self, timeout, confidence=0.95):
21982198
21992199
>>> rdd = sc.parallelize(range(1000), 10)
22002200
>>> r = sum(range(1000))
2201-
>>> (rdd.sumApprox(1000) - r) / r < 0.05
2201+
>>> abs(rdd.sumApprox(1000) - r) / r < 0.05
22022202
True
22032203
"""
22042204
jrdd = self.mapPartitions(lambda it: [float(sum(it))])._to_java_object_rdd()
@@ -2215,7 +2215,7 @@ def meanApprox(self, timeout, confidence=0.95):
22152215
22162216
>>> rdd = sc.parallelize(range(1000), 10)
22172217
>>> r = sum(range(1000)) / 1000.0
2218-
>>> (rdd.meanApprox(1000) - r) / r < 0.05
2218+
>>> abs(rdd.meanApprox(1000) - r) / r < 0.05
22192219
True
22202220
"""
22212221
jrdd = self.map(float)._to_java_object_rdd()

0 commit comments

Comments
 (0)