码迷,mamicode.com
首页 > 其他好文 > 详细

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

时间:2019-08-11 13:37:57      阅读:100      评论:0      收藏:0      [点我收藏+]

标签:int   总结   class   元素   扩展   多个   pre   一个   array   

与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

标签:int   总结   class   元素   扩展   多个   pre   一个   array   

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

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!