def foo(extra_arg): …. def bar(row): # your code here return bar
then pass foo(extra_arg) to spark map function. -- Best Regards! On Thursday, August 21, 2014 at 2:33 PM, TJ Klein wrote: > Hi, > > I am using Spark in Python. I wonder if there is a possibility for passing > extra arguments to the mapping function. In my scenario, after each map I > update parameters, which I want to use in the folllowning new iteration of > mapping. Any idea? > > Thanks in advance. > > -Tassilo > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Mapping-with-extra-arguments-tp12541.html > Sent from the Apache Spark User List mailing list archive at Nabble.com > (http://Nabble.com). > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > (mailto:user-unsubscr...@spark.apache.org) > For additional commands, e-mail: user-h...@spark.apache.org > (mailto:user-h...@spark.apache.org) > >