回复：flink 1.13.0 中cumulate window 使用

Thu, 27 May 2021 21:38:00 -0700 

Hello
请参考官网案例，需要使用 window tvf语法。


https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/queries/window-tvf/#cumulate


Best
fanrui



---原始邮件---
发件人: "邹云鹤"<[email protected]&gt;
发送时间: 2021年5月28日(周五) 中午11:44
收件人: "user-zh"<[email protected]&gt;;
主题: flink 1.13.0 中cumulate window 使用


insert into `test_out` select a.uid, 'dt', max(a.age) from `test_in` as a group 
by uid, cumulate(PROCTIME(), interval '1' minute, interval '1' hour);


hello， 各位大佬， flink 1.13.0 中流式作业中该怎么使用cumulate window呢？我用上面的SQL 貌似是不行， 
有没有使用过的大佬给点建议？




| |
邹云鹤
|
|
[email protected]
|
签名由网易邮箱大师定制

回复