首页 > 其他 > 详细

Spark常用的算子总结(2)——flatMap

时间:2019-08-11 14:36:52      阅读:104      评论:0      收藏:0      [点我收藏+]
与map类似,区别是原RDD中的元素经map处理后只能生成一个元素,而原RDD中的元素经flatmap处理后可生成多个元素

val a = sc.parallelize(1 to 4, 2)
val b = a.flatMap(x => 1 to x)//每个元素扩展
b.collect
/*
结果    Array[Int] = Array( 1, 
                           1, 2, 
                           1, 2, 3, 
                           1, 2, 3, 4)
*/

 

Spark常用的算子总结(2)——flatMap

原文:https://www.cnblogs.com/pocahontas/p/11334558.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!