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

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

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

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


Best,
Xiao


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


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