You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by BenChen <ha...@163.com> on 2020/09/01 05:43:48 UTC
关于FlinkSQL的窗口和触发
Hi all,
在FlinkSQL中,我知道可以通过group by window去做窗口处理,但是如果触发时间和窗口时间不一致,如何去表达呢?
比如说,统计一天的PV和UV,每隔10S更新数据,在StreamingApi里面,可以通过timeWindow(1Day) + trigger(10Seconds)去实现,但是到FlinkSQL上要如何实现呢?
感激不尽。
| |
BenChen
|
|
haibin369@163.com
|
签名由网易邮箱大师定制
回复:关于FlinkSQL的窗口和触发
Posted by Cayden chen <11...@qq.com>.
hi,目前不支持。sql语义只支持窗口结束触发计算
------------------ 原始邮件 ------------------
发件人: "user-zh" <haibin369@163.com>;
发送时间: 2020年9月1日(星期二) 中午1:43
收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
主题: 关于FlinkSQL的窗口和触发
Hi all,
在FlinkSQL中,我知道可以通过group by window去做窗口处理,但是如果触发时间和窗口时间不一致,如何去表达呢?
比如说,统计一天的PV和UV,每隔10S更新数据,在StreamingApi里面,可以通过timeWindow(1Day) + trigger(10Seconds)去实现,但是到FlinkSQL上要如何实现呢?
感激不尽。
| |
BenChen
|
|
haibin369@163.com
|
签名由网易邮箱大师定制