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 [1, 2, 1, 2, 3, 1, 2, 3, ...
確定! 回上一頁