Send Simple text Files as Dstream

DStreamSimpleText.scala

import org.apache.spark._
import org.apache.spark.streaming._
import org.apache.spark.streaming.dstream.DStream
object DStreamSimpleText extends App {
  val conf = new SparkConf().setMaster("local[*]").setAppName("App name")
  val sc = new SparkContext(conf)
  val ssc = new StreamingContext(sc, Seconds(5))
  val filestream: DStream[String] = ssc.textFileStream(
    "/Users/deepakjayaprakash/Downloads/testing"
  ) // read new file
  val word: DStream[(String, Int)] =
    filestream.flatMap(f => f.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)
  word.print() //Shd have - foreachRDD / saveAsTextFiles / print
  ssc.start()
  ssc.awaitTermination()

}