Spark2.3.2源码解析: 算子解析 [ 二 . Value数据类型的Transformation算子  ]

  本文讲述的是[   Value数据类型的Transformation算子   ] 分类的算子.    一、输入分区与输出分区一对一型       1、map算子   将原来 RDD 的每个数据项通过 map 中的用户自定义函数 f 映射转变为一个新的元素。源码中 map 算子相当于初始化一个 RDD, 新 RDD 叫做 MappedRDD(this, sc.clean(f))。   图 1中每
相关文章
相关标签/搜索