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

夏沐沐

关注

阅读 160

2022-04-05

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

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

对吧

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

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

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

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

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

UNBOUNDED_ROW对吧,其实是差不多的

精彩评论(0)

0 0 举报