1.对一个数据为{1，2，3，3}的RDD进行基本的RDD转化操作
| 函数名 | 目的 | 示例 | 结果 |
|
map() |
函数应用于RDD中的每个元素 | rdd.map(x=>x+1) | {2,3,4,4} |
| flatMap() | 将函数应用于RDD中的每个怨毒，通常用来切分单词 | rdd.flatMap(x=>x.to(3)) | {1,2,3,2,3,3,3} |
| filter() | 返回一个通过传给filter()的函数的元素组成的RDD | rdd.filter(x=>x!=1) | {2,3,3} |
| distinct() | 去重 | rdd.distinct() |
{1,2,3} |
| sample(withReplacement,fraction,[seed]) | 对RDD进行采样，以及是否替换 | rdd.sample(false,0.5) | 非确定 |
2.对数据分别为{1，2，3}和{3，4，5}的RDD进行针对两个RDD的转化
原文：http://www.cnblogs.com/nolonely/p/5402698.html