你指的是TopN吗?https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/queries.html#top-n
但我想知道window topN写法,跟这个还不一样。
我的需求是:
cdc场景同一个主键数据变更频繁,我想定义一个5秒处理时间窗口,在该窗口内取同一主键最新变更记录。用flink sql 1.12如何实现?

















在 2021-06-23 10:18:01,"杨光跃" <[email protected]> 写道:
>
>
>Apache Flink 1.12 Documentation: Queries
>| |
>杨光跃
>|
>|
>[email protected]
>|
>签名由网易邮箱大师定制
>在2021年6月23日 10:09,casel.chen<[email protected]> 写道:
>请不要截图哦
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>在 2021-06-23 09:47:46,"杨光跃" <[email protected]> 写道:
>
>1.12也支持的
>| |
>杨光跃
>|
>|
>[email protected]
>|
>签名由网易邮箱大师定制
>在2021年6月23日 09:45,casel.chen<[email protected]> 写道:
>官网文档上显示flink 1.13支持window topN,但flink 1.12没看到相关文档,请问有什么work around方法吗?

回复