当前位置: article > 正文

大数据_Flink_Java版_Table API 和 Flink SQL(15)_开窗函数---Flink工作笔记0095_flinksql开窗函数

作者：IT小白 | 2024-05-28 19:49:02

踩

flinksql开窗函数

然后我们再来看table api中提供的over这个类

可以看到这个OverWindow,可以让我们声明完以后直接进行sum,min等的聚合操作

对吧

可以看到这里over这个类可以进行,对无界流的处理,

这里无界流,指的是,对迄今为止收到的所有数据进行处理对吧,可以看到

这里Over.partitionBy("a")这个相当于分组对吧,然后

orderBy这个相当于,排序,然后preceding这个是,相当于

指定是UNBOUNDED_RANCE,无界的流对吧,然后再看,还有一个是按照行的

UNBOUNDED_ROW对吧,其实是差不多的

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