你指的是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方法吗?
