WordCount.scala

/* SimpleApp.scala */
import org.apache.spark.SparkContext
import org.apache.spark.SparkContext._
import org.apache.spark.SparkConf

object WordCountApp {
  def main(args: Array[String]) {
    val conf = new SparkConf().setAppName("WordCount Application")
    val sc = new SparkContext(conf)
    val textFile = sc.textFile("file:///mnt/Data/textfile.txt")
    val counts = textFile.flatMap(line => line.split(" ")).map(word => (word,1)).reduceByKey(_ + _)
    counts.saveAsTextFile("file:///tmp/Output.txt")
    sc.stop()
  }
}