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