事件间隔时间

lawou6xi  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(260)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题