SparkCore-容易混淆的RDD算子區別(Scala版本)

1.map與flatMap的區別code # 初始化數據 val rdd1 = sc.parallelize(Array("hello world","i love you")) 1.1  mapit # map算子 rdd1.map(_.split(" ")).collect # map算子結果輸出 res0: Array[Array[String]] = Array(Array(hello,
相關文章
相關標籤/搜索