0
点赞
收藏
分享

微信扫一扫

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

夏沐沐 2022-04-05 阅读 160

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

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

对吧

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

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

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

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

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

UNBOUNDED_ROW对吧,其实是差不多的

举报

相关推荐

0 条评论