From ee17d7846438e270967e38120d0fb6c63523defd Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Wed, 19 Nov 2014 10:58:03 -0800 Subject: [PATCH] remove = for float --- python/pyspark/rddsampler.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/pyspark/rddsampler.py b/python/pyspark/rddsampler.py index fd7639ff7a138..5928b1d892de0 100644 --- a/python/pyspark/rddsampler.py +++ b/python/pyspark/rddsampler.py @@ -70,7 +70,7 @@ def func(self, split, iterator): yield obj else: for obj in iterator: - if self.getUniformSample() <= self._fraction: + if self.getUniformSample() < self._fraction: yield obj @@ -106,5 +106,5 @@ def func(self, split, iterator): yield key, val else: for key, val in iterator: - if self.getUniformSample() <= self._fractions[key]: + if self.getUniformSample() < self._fractions[key]: yield key, val