我想计算两个DStreams不同窗口的差异(按键)。 这可以通过一个连接来完成。 不过,我想有DStreams之间的偏移。 这样做的一个方法是将掉落DStreams之一的N个窗口,但我不知道该怎么做,要么。
文章来源: How can I perform an operation on two windowed DStreams with an offset?
我想计算两个DStreams不同窗口的差异(按键)。 这可以通过一个连接来完成。 不过,我想有DStreams之间的偏移。 这样做的一个方法是将掉落DStreams之一的N个窗口,但我不知道该怎么做,要么。