Skip to content

Commit

Permalink
added a TODO for logging in python
Browse files Browse the repository at this point in the history
  • Loading branch information
dorx committed Jun 12, 2014
1 parent 46f6c8c commit 50581fc
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/pyspark/rdd.py
Original file line number Diff line number Diff line change
Expand Up @@ -385,6 +385,7 @@ def takeSample(self, withReplacement, num, seed=None):
# See: scala/spark/RDD.scala
rand = Random(seed)
while len(samples) < total:
#TODO add log warning when more than one iteration was run
samples = self.sample(withReplacement, fraction, rand.randint(0, sys.maxint)).collect()

sampler = RDDSampler(withReplacement, fraction, rand.randint(0, sys.maxint))
Expand Down

0 comments on commit 50581fc

Please sign in to comment.