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."))

同じことに関するヘルプは大歓迎です。