Data into Socket

DStreamSoacket.scala

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.streaming.dstream.DStream
//nc -l -p 9999
object DStreamSoacket extends App {
  val conf = new SparkConf().setMaster("local[*]").setAppName("App name")
  val sc = new SparkContext(conf)
  val ssc = new StreamingContext(sc, Seconds(5))
  val lines: DStream[String] = ssc.socketTextStream(hostname = "localhost", port = 9999)
  val wordCounts = lines.flatMap(_.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)
  wordCounts.print()
  ssc.start()
  ssc.awaitTermination()
}