scala - 如何对具有偏移量的两个窗口化 DStream 执行操作？

Question

我想计算两个具有不同窗口的 DStream 的差异（按键）。这可以通过连接来完成。但是，我想在 DStreams 之间有一个偏移量。一种方法是删除其中一个 DStream 的 N 个窗口，但我也不知道该怎么做。