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
- Question on mappartitionwithsplit Chengi Liu
- Re: Question on mappartitionwithsplit Davies Liu
- Re: Question on mappartitionwithsplit Chengi Liu
- Re: Question on mappartitionwithsplit Mohit Singh
- Re: Question on mappartitionwithsplit Davies Liu
- Re: Question on mappartitionwithsplit Josh Rosen