Watch this video on YouTube
Which of the following methods can be used to define a function which can be executed on the output of every micro-batch in a Spark Streaming query?