Hi All,

I currently do the following

val jsonDStream = getJsonDStream()

jsonDStream.foreachRDD{rdd =>
    val jsonDF = spark.read.json(rdd)
    jsonDF.createOrReplaceTempView("dataframe")
}
client.startStream()

%spark.sql select * from dataframe

I can see the data and everytime I click a run button I can see the updates
as well however is there anyway to update this dashboard/UI/Graph through
web socket? Don't want to do polling.

Thanks!

Reply via email to