2016-10-02 2 views

답변

0

시도하십시오처럼 이익의 요약을 검색하는 것입니다 이하. 여기

val firstRDD = sc.textFile("/path_to_file/file.txt").map(line =>line.split("\\|")(1)) 

val resultRDD=firstRDD.flatMap(line => line.split(",")).map(word => (word,1)).reduceByKey(_+_) 

resultRDD.collect 

스칼라로부터의 출력은 셸

res23: Array[(String, Int)] = Array((reading,1), (cooking,2), (travelling,1), (running,1), (riding,2))