Filecoin 协程 软件测试工程师 劝酒文化 web serialization 如何做网络营销推广 swift2 后台管理页面模板 郑州网络 河南网络推广 idea生成main方法 oracle删除字段 git登陆命令 string转16进制 python课程 python获取字典的值 python排序 java8时间 java匿名对象 java定义变量 java泛型的使用 java中map java8函数式编程 javalist转数组 javascript实例 abaqus最新版本 销售单打印软件 volist din字体 端口关闭工具 全英雄守城战 php小数点保留2位 c程序 复仇之矛天赋 汇通启富下载 mac修改器 保留两位小数的函数 斐讯k3刷机 产品修图
当前位置: 首页 > 学习教程  > 编程语言

rdd算子解决需求一

2020/12/5 10:34:12 文章标签:

//分区内的最大值 val rdd sc.makeRDD(List(1,2,3,4),2) val mprdd rdd.mapPartitions(iter > { List(iter.max).iterator }) mprdd.collect().foreach(println)解决思想 mappartition返回的是一个迭代器 所以liter.max要转为iteration 方法list.teration

//分区内的最大值
val rdd = sc.makeRDD(List(1,2,3,4),2)
val mprdd = rdd.mapPartitions(iter => {
List(iter.max).iterator
})

mprdd.collect().foreach(println)

解决思想
mappartition返回的是一个迭代器
所以liter.max要转为iteration
方法list.teration


本文链接: http://www.dtmao.cc/news_show_450268.shtml

附件下载

相关教程

    暂无相关的数据...

共有条评论 网友评论

验证码: 看不清楚?