回复：flink sql 窗口场景的问题

[shao.hongxiao]

考虑使用滑动窗口和步长




| |
邵红晓
|
|
邮箱：17611022...@163.com
|

签名由 网易邮箱大师 定制

在2020年06月03日 08:22，smq 写道：
我觉得既然你想要事实输出数据，那就没必要用窗口，用了时间窗口，那就是按照窗口大小来统计了，不能同时两个都实现吧，把这两种场景分开分别实现，或者你要想得到每分钟的聚合结果，就缩小窗口大小。


---原始邮件---
发件人: &quot;steven chen&quot;<stevenche...@163.com&gt;
发送时间: 2020年6月3日(周三) 凌晨2:49
收件人: &quot;user-zh@flink.apache.org&quot;<user-zh@flink.apache.org&gt;;
主题: flink sql 窗口场景的问题


hi ：
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 我现在遇到有这样一个场景，我们需要实时去统计5分和30分的粒度，flink sql 
窗口使用了处理时间滚动窗口方式
但是都是只有5分结束的时候才能把聚合结果输出，这个不满足我们需求，有没有方式可以直接实时输出结果，比如18:02 的统计+1+1 
都能直接落在18:00-18:05的窗口上，并每次+1都能实时输出，而不是等到窗口结束才sink 到mysql .30分钟同5分种，这种flink sql 
如何实现。

比如数据
{ts: 2019-12-10 16:24:00 id: 1}
{ts: 2019-12-10 16:22:00 id: 1}
{ts: 2019-12-10 16:23:00 id: 2}
{ts: 2019-12-10 16:21:00 id: 1}
{ts: 2019-12-10 16:29:00 id: 2}
{ts: 2019-12-10 16:27:00 id: 3}
{ts: 2019-12-10 16:26:00 id: 2}







&nbsp;