Flink:窗口评估
Flink:窗口评估
提问于 2017-01-11 16:22:38
我正在使用real_time数据流的window(SlidingEventTimeWindows.of(Time.seconds(120), Time.seconds(1)))滑动窗口。我还使用接口AssignerWithPeriodicWatermarks来提取时间戳并分配水印。我正在对开窗流应用自定义方法apply()。
在这个场景中，触发窗口评估(apply()执行)的是每隔1秒发生一次。哪一个等于窗口滑动，或者是遇到流中的水印后？
回答
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/41585860
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号