flatmap_rdd = sc.parallelize(["Hey there", "This is PySpark RDD Transformations"]) (flatmap_rdd.flatMap(lambda x: x.split(" ")).collect()).
確定! 回上一頁