Restart streaming query spark 2.1 structured streaming

[purna pradeep]

Hi,

>
> I'm trying to restart a streaming query to refresh cached data frame
>
> Where and how should I restart streaming query
>


val sparkSes = SparkSession

      .builder

      .config("spark.master", "local")

      .appName("StreamingCahcePoc")

      .getOrCreate()



    import sparkSes.implicits._



    val dataDF = sparkSes.readStream

      .schema(streamSchema)

      .csv("testData")





       val query = counts.writeStream

      .outputMode("complete")

      .format("console")

      .start()


query.awaittermination()



>
>
>