※ 引述《iwantstronge (...)》之铭言：
: 版友们好~
: 最近刚学Scala, 有个问题卡了很久
: 当我把档案用RDD读进来:
: val input = sc.textfile("myfile.txt")
: 接着逐行读取这个档案(RDD),
: 在里面用一个容器(HashMap, Array, List之类的)储存每一行的一些资讯
input.map(line => (line, 1)).reduceByKey(_ + _).collect
回传是一个tuple array 自己再转回HashMap
更简单的是
input.distinct().collect