Here's an example of PySpark's flatMap on an RDD: sc.parallelize([3,4,5]).flatMap(lambda x: range(1,x)).collect(). which will yield
確定! 回上一頁