spark read stream data

stream.scala

import org.apache.spark.sql.SparkSession

object SimpleStream extends App {

  val spark = SparkSession.builder
    .master("local")
    .appName("StructuredNetworkWordCount")
    .getOrCreate()
  spark.sparkContext.setLogLevel("ERROR")

  import spark.implicits._
  val lines = spark.readStream
    .format("socket")
    .option("host", "localhost")
    .option("port", 9999)
    .load()

  // Split the lines into words
  val words = lines.as[String].flatMap(_.split(" ")) //DF > Dataset

  // Generate running word count
//  val wordCounts = words.groupBy("value").count()
  val query = lines.writeStream
    .outputMode("complete") //append ,update
    .format("console")
    .start()

  query.awaitTermination()

}