1. map 和 flatMap
map就是對rdd之中的元素進(jìn)行逐一進(jìn)行函數(shù)操作映射為另外一個(gè)rdd奔滑。
flatMap的操作是將函數(shù)應(yīng)用于rdd之中的每一個(gè)元素,將返回的迭代器的所有內(nèi)容構(gòu)成新的rdd帮毁。
map和flatMap
2.CombineByKey
再來看一個(gè)例子
1. map 和 flatMap
map就是對rdd之中的元素進(jìn)行逐一進(jìn)行函數(shù)操作映射為另外一個(gè)rdd奔滑。
flatMap的操作是將函數(shù)應(yīng)用于rdd之中的每一個(gè)元素,將返回的迭代器的所有內(nèi)容構(gòu)成新的rdd帮毁。
2.CombineByKey
再來看一個(gè)例子