scala - オフセットを使用して 2 つのウィンドウ化された DStream で操作を実行するにはどうすればよいですか?

Question

異なるウィンドウを持つ 2 つの DStream の違いを (キーで) 計算したいと思います。これは、結合によって実現できます。ただし、DStreams 間にオフセットが必要です。これを行う 1 つの方法は、DStreams の 1 つの N ウィンドウを削除することですが、その方法もわかりません。