SimpleCountStreamSpark.scala

import org.apache.spark._
import org.apache.spark.streaming._
import org.apache.spark.SparkConf


object SimpleStreamingApp {
  def main(args:Array[String]) {
    val conf = new SparkConf().setMaster("local[2]").setAppName("Simple App")
    val ssc = new StreamingContext(conf, Seconds(45))  // Time window of 45 second. 
    val lines = ssc.socketTextStream("localhost", 9999)
    val words = lines.flatMap(_.split(" "))
    val pairs = words.map(word => (word, 1))
    val wordCount = pairs.reduceByKey(_+_)
    wordCount.print()

    ssc.start()
    ssc.awaitTermination()
  }

}