https://medium.com/@bartoszgajda55/unit-testing-apache-spark-structured-streaming-using-memorystream-8e77e97c5f5d