flink窗口函数原理深入_flink sql 窗口函数原理

作者：你好赵伟 | 2024-05-28 19:53:42

踩

flink sql 窗口函数原理

写在前头：

更多大数据相关精彩内容请进我的知识星球，每周定期更新

正篇

Flink SQL支持四种窗口函数，分别是Window聚合：滚动窗口（TUMBLE）、滑动窗口（HOP）、会话窗口（SESSION），OVER聚合：OVER窗口。

说到是时间窗口操作，那么涉及到Flink SQL可以基于两种时间属性对数据进行窗口聚合。

Event Time:事件时间（数据最原始的创建时间），在给定的数据源中的Schema中，比如我的客流数据一个字段是客流发生时间，那么事件时间就是客流发生该字段。

Processing Time:对事件进行处理的本地系统时间。

（Flink SQL暂不支持）Ingestion Time

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/639040