Re: flink cdc 读取数据后面可以跟窗口函数吗

[Hang Ruan <ru...@gmail.com>]

你好，

CDC Source 目前不支持窗口函数。

不过可以考虑通过非窗口聚合的方式实现类似的效果。具体方法为：

   1.

   使用DATE_FORMAT函数，将时间字段转换成分钟粒度的字符串，作为窗口值。
   2.

   根据窗口值进行GROUP BY聚合。

Best,
Hang

Xuyang <xy...@163.com> 于2024年1月17日周三 19:34写道：

> Hi,
> Flink SQL中可以用Group Window[1]的方式来读完cdc数据后加窗口。
> 可以具体描述一下“一直不生效”的现象和SQL么？
>
>
>
> [1]
> https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/queries/window-agg/#selecting-group-window-start-and-end-timestamps-1
>
>
>
>
> --
>
>     Best！
>     Xuyang
>
>
>
>
>
> 在 2024-01-17 19:24:03，"2813732510" <28...@qq.com.INVALID> 写道：
> >flink&nbsp;&nbsp;cdc&nbsp;读取binlog数据后面可以开窗吗，测试滑动窗口，聚合，一直不生效，是有什么特别的用法嘛
>

回复： flink cdc 读取数据后面可以跟窗口函数吗

[王凯 <28...@qq.com.INVALID>]

好的,感谢




王凯
2813732510@qq.com



 





------------------ 原始邮件 ------------------
发件人:                                                                                                                        "user-zh"                                                                                    <ruanhang1993@gmail.com&gt;;
发送时间:&nbsp;2024年1月18日(星期四) 上午10:16
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: flink cdc 读取数据后面可以跟窗口函数吗



你好，

CDC Source 目前不支持窗口函数。

不过可以考虑通过非窗口聚合的方式实现类似的效果。具体方法为：

&nbsp;&nbsp; 1.

&nbsp;&nbsp; 使用DATE_FORMAT函数，将时间字段转换成分钟粒度的字符串，作为窗口值。
&nbsp;&nbsp; 2.

&nbsp;&nbsp; 根据窗口值进行GROUP BY聚合。

Best,
Hang

Xuyang <xyzhong131@163.com&gt; 于2024年1月17日周三 19:34写道：

&gt; Hi,
&gt; Flink SQL中可以用Group Window[1]的方式来读完cdc数据后加窗口。
&gt; 可以具体描述一下“一直不生效”的现象和SQL么？
&gt;
&gt;
&gt;
&gt; [1]
&gt; https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/queries/window-agg/#selecting-group-window-start-and-end-timestamps-1
&gt;
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp; Best！
&gt;&nbsp;&nbsp;&nbsp;&nbsp; Xuyang
&gt;
&gt;
&gt;
&gt;
&gt;
&gt; 在 2024-01-17 19:24:03，"2813732510" <2813732510@qq.com.INVALID&gt; 写道：
&gt; &gt;flink&amp;nbsp;&amp;nbsp;cdc&amp;nbsp;读取binlog数据后面可以开窗吗，测试滑动窗口，聚合，一直不生效，是有什么特别的用法嘛
&gt;