spark操作RDD的 map,flatMap及CombineB
2019-04-03 本文已影响0人
越走越远的风
1. map 和 flatMap
map就是对rdd之中的元素进行逐一进行函数操作映射为另外一个rdd。
flatMap的操作是将函数应用于rdd之中的每一个元素,将返回的迭代器的所有内容构成新的rdd。
map和flatMap2.CombineByKey
再来看一个例子
1. map 和 flatMap
map就是对rdd之中的元素进行逐一进行函数操作映射为另外一个rdd。
flatMap的操作是将函数应用于rdd之中的每一个元素,将返回的迭代器的所有内容构成新的rdd。
map和flatMap2.CombineByKey
再来看一个例子