Fink SQL 实践之OVER窗口

Flink SQL 是一种使用 SQL 语义设计的开发语言，用它解决具体业务需求是一种全新体验，类似于从过程式编程到函数式编程的转变一样，需要一个不断学习和实践的过程。在看完了 Flink 官方文档中 SQL 部分 ，以及官方提供的 SQL Training 后，觉得自己装备了必杀技准备横扫需求了，这时先来一个简单的营销需求：实时计算今天用户加页面维度的浏览次数，即实时输出PV，下游根据某些规则比如今天用户浏览A页面达到N次触发某种动作。当我使用 group by user 并输出到 kafka 中时，发生异常： AppendStreamTableSink requires that Table has only insert changes，这是因为不带时间窗口的分组聚合不支持流式输出，依赖 Flink Dynamic Tables 的实现原理。修改后加上时间窗口但是不支持实时触发，只在窗口结束时输出一次结果，总之仔细翻了个遍，发现上面资料中都没有类似场景，不会这么简单都实现不了吧？Flink SQL 是一种使用 SQL 语义设计的开发语言，用它解决具体业务需求是一种全新