You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by kcz <57...@qq.com> on 2020/07/03 11:11:37 UTC

回复:Flink sql 主动使数据延时一段时间有什么方案

设置一个窗口时间,如果有需要取最新的,可以再做一下处理。





------------------ 原始邮件 ------------------
发件人: admin <17626017841@163.com&gt;
发送时间: 2020年7月3日 18:01
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:Flink sql 主动使数据延时一段时间有什么方案



补充一下:明确的说是维表的join,A表关联B表(维表),想让A表延迟一会再关联B表

&gt; 2020年7月3日 下午5:53,admin <17626017841@163.com&gt; 写道:
&gt; 
&gt; Hi,all
&gt; 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。
&gt; FLink sql有什么方案实现吗?
&gt; 
&gt; 感谢您的回复

回复:Flink sql 主动使数据延时一段时间有什么方案

Posted by "Sun.Zhu" <17...@163.com>.

窗口得用group by,字段会丢失
在2020年07月03日 19:11,kcz 写道:
设置一个窗口时间,如果有需要取最新的,可以再做一下处理。





------------------ 原始邮件 ------------------
发件人: admin <17626017841@163.com&gt;
发送时间: 2020年7月3日 18:01
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:Flink sql 主动使数据延时一段时间有什么方案



补充一下:明确的说是维表的join,A表关联B表(维表),想让A表延迟一会再关联B表

&gt; 2020年7月3日 下午5:53,admin <17626017841@163.com&gt; 写道:
&gt;
&gt; Hi,all
&gt; 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。
&gt; FLink sql有什么方案实现吗?
&gt;
&gt; 感谢您的回复