1
条回答
写回答
写回答
-
① Processing time：根据task所在节点的本地时间来切分时间窗口 ② event time：消息自带时间戳，但是这种时间是有延时的，也就是乱序的，为了防止同一个窗口的message被正确处理，所以需要其他方法如watermark，说白了就是给一个延时容忍度，然后根据watermark来判断窗口的划分，然后再根据trigger的类型判断什么时候进行计算 ③ ingestion time：有的消息本身不携带时间戳，但是用户依然希望按照消息而不是节点时钟划分窗口，在message进入flink的时候给他一个递增的时间，是event time的一种特例，用的很少
2021-12-08 15:05:16赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
