Spark shell 統計word count程序

1、啓動hdfs  2、啓動Spark 3、進入Spark shell    UI 界面顯示如下 4 、在scala 命令行中執行如下代碼 sc.textFile("hdfs://bigdata121:9000/tmp/spark/data.txt").flatMap(_.split(" ")).map((_,1)).reduceByKey(_+_).saveAsTextFile("hdfs://

>>阅读原文<<