关于FlinkSQL的窗口和触发

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

关于FlinkSQL的窗口和触发

BenChen
Hi all,
在FlinkSQL中,我知道可以通过group by window去做窗口处理,但是如果触发时间和窗口时间不一致,如何去表达呢?
比如说,统计一天的PV和UV,每隔10S更新数据,在StreamingApi里面,可以通过timeWindow(1Day) + trigger(10Seconds)去实现,但是到FlinkSQL上要如何实现呢?


感激不尽。


| |
BenChen
|
|
[hidden email]
|
签名由网易邮箱大师定制