怎样给Spark传递函数？

Question

怎样给Spark传递函数

Answer 1

大讲台 spark在线培训为你解答：
第一种：匿名函数，处理的代码比较少的时候，可以采用匿名函数，直接写在算子里面：
myrdd.map(x => x+ 1)
第二种：全局单例对象中的静态方法：先定义object对象MyFunctions，以及静态方法：funcOne,然后传递MyFunctions.funcOne给RDD算子。
object MyFunctions {
def funcOne(s: String): String = { ... }
}
myRdd.map(MyFunctions.funcOne)