关于FlinkSQL的窗口和触发

Mon, 31 Aug 2020 22:44:17 -0700 

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


感激不尽。


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

回复