Spark:WordCount 步驟

scala> val data = sc.textFile("/library/wordcount/input/Data") //data: org.apache.spark.rdd.RDD[String] = MapPartitionsRDD[9] at textFile as <console>:27 scala> val flatted = data.flatMap(_.split("

>>阅读原文<<