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,
相关文章
相关标签/搜索