Add numbers in a DStream

sparkStreaming-basics.scala

/*
Add the numbers coming into each DStream of data
*/

import org.apache.spark.streaming.StreamingContext
import org.apache.spark.streaming.Seconds
import org.apache.spark.{SparkConf, SparkContext}

val conf = new SparkConf().setAppName("sbtapp").setMaster("local[3]")
val ssc = new StreamingContext(conf,Seconds(5))
val lines = ssc.socketTextStream("localhost",9999)
	//org.apache.spark.streaming.dstream.ReceiverInputDStream[String]
	//so 'lines' is a DStream of [Strings]
val result = lines.map(x=> x.toInt).reduce((a,n) => a+n)
result.print
ssc.start
/*
.....On the command line use: 
      nc -L -p 9999 -v
     --then type numbers followed by 'enter-key'
*/
ssc.stop(true)