unit-testing - 模拟输入 dstream apache spark

Question

我试图在编写火花流单元测试时模拟输入 dstream。我可以模拟 RDD，但是当我尝试将它们转换为 dstream 时，dstream 对象变为空。我使用了以下代码-

val lines = mutable.Queue[RDD[String]]()
val dstream = streamingContext.queueStream(lines)

// append data to DStream
lines += sparkContext.makeRDD(Seq("To be or not to be.", "That is the question."))

任何有关相同的帮助将不胜感激。