RDD介紹

transformation 轉換： map： lines.map(word => (word,1)) filter: lines.filter(word => word.cotains("hello")) flatmap 壓扁: 一個輸入對應多個輸出 例如讀取一個文本文件產生的結果 會全部在一層或者是一行 就是被壓扁了 val inputs=sc.textFile("/user/test.txt

>>阅读原文<<