Scala Programming Projects

Drawing a scatter chart

Since we have a running StreamingQuery that writes to an in-memory table called transactionsStream, we can display the data contained in this table with the following paragraph:

z.show(spark.table("transactionsStream").sort("timestamp"))

Run this paragraph, and if you have some transactions coming into your Kafka topic, you should see a table which looks like this:

You can then click on the scatter chart button. If you want to draw the evolution of the price, you can drag and drop the timestamp in the x axis and the price in the y axis. You should see something like this:

If you want to refresh the chart with the latest ...