Stream-stream Joins using Structured Streaming [Scala]