RDD介绍

transformation 转换： map： lines.map(word => (word,1)) filter: lines.filter(word => word.cotains("hello")) flatmap 压扁: 一个输入对应多个输出 例如读取一个文本文件产生的结果 会全部在一层或者是一行 就是被压扁了 val inputs=sc.textFile("/user/test.txt

>>阅读原文<<