Hi,
  In this example:
http://www.cs.berkeley.edu/~pwendell/strataconf/api/pyspark/pyspark.rdd.RDD-class.html#mapPartitionsWithSplit
Let say, f takes three arguments:
def f(splitIndex, iterator, foo): yield splitIndex
Now, how do i send this foo parameter to this method?
rdd.mapPartitionsWithSplit(f)
Thanks

Reply via email to