回复：关于FlinkSQL的窗口和触发

Tue, 01 Sep 2020 02:31:21 -0700 

Hi:
可以试试增加如下配置：
table.exec.emit.early-fire.enabled = true
  table.exec.emit.early-fire.delay = 10000


Best,
Xiao


 原始邮件 
发件人: Cayden chen<[email protected]>
收件人: user-zh<[email protected]>
发送时间: 2020年9月1日(周二) 17:10
主题: 回复：关于FlinkSQL的窗口和触发


hi，目前不支持。sql语义只支持窗口结束触发计算 ------------------&nbsp;原始邮件&nbsp;------------------ 
发件人: "user-zh" <[email protected]&gt;; 发送时间:&nbsp;2020年9月1日(星期二) 中午1:43 
收件人:&nbsp;"[email protected]"<[email protected]&gt;; 
主题:&nbsp;关于FlinkSQL的窗口和触发 Hi all， 在FlinkSQL中，我知道可以通过group by 
window去做窗口处理，但是如果触发时间和窗口时间不一致，如何去表达呢？ 
比如说，统计一天的PV和UV，每隔10S更新数据，在StreamingApi里面，可以通过timeWindow(1Day) + 
trigger(10Seconds)去实现，但是到FlinkSQL上要如何实现呢？ 感激不尽。 | | BenChen | | 
[email protected] | 签名由网易邮箱大师定制

回复