建立接收 python RDD 的 Scala 函式

建立一個接收 python RDD 的 Scala 函式很簡單。你需要構建的是一個獲得 JavaRDD [Any]的函式

import org.apache.spark.api.java.JavaRDD

def doSomethingByPythonRDD(rdd :JavaRDD[Any]) = {
    //do something
    rdd.map { x => ??? }
}