spark例子

MAP变换例子: 用map 给英语成绩+1分给数学成绩-1分函数 flatMap() (1)reduce():并行汇总全部RDD元素spa reduce()参数是一个函数,这个函数有两个参数(首先会分区(默认分区数量与虚拟机的核心数有关,个人是2),而后每一个分区得出结果最后汇总),两个参数分别是每次分区后两个分区的结果3d 执行过程:blog 分区:[(1,2),(3,4)]ip 第一次结果:[
相关文章
相关标签/搜索