我开始用apache flink做实验，并取得了一些非常基本的成果。现在我期待着找出连续元素之间的时间差。
我的想法是在流上使用countwindowall（2），这样我就可以用两个连续的事件来评估windows。但是，我不明白如何访问窗口中2个事件的时间戳，以将其发射/Map为时差。
是否有人有一个很好的参考，甚至一些例子代码，我试图实现？
拉尔斯