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>
发送时间: 2020年7月3日 18:01
收件人: user-zh <user-zh@flink.apache.org>
主题: 回复:Flink sql 主动使数据延时一段时间有什么方案
补充一下:明确的说是维表的join,A表关联B表(维表),想让A表延迟一会再关联B表
> 2020年7月3日 下午5:53,admin <17626017841@163.com> 写道:
>
> Hi,all
> 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。
> FLink sql有什么方案实现吗?
>
> 感谢您的回复
回复:Flink sql 主动使数据延时一段时间有什么方案
Posted by "Sun.Zhu" <17...@163.com>.
窗口得用group by,字段会丢失
在2020年07月03日 19:11,kcz 写道:
设置一个窗口时间,如果有需要取最新的,可以再做一下处理。
------------------ 原始邮件 ------------------
发件人: admin <17626017841@163.com>
发送时间: 2020年7月3日 18:01
收件人: user-zh <user-zh@flink.apache.org>
主题: 回复:Flink sql 主动使数据延时一段时间有什么方案
补充一下:明确的说是维表的join,A表关联B表(维表),想让A表延迟一会再关联B表
> 2020年7月3日 下午5:53,admin <17626017841@163.com> 写道:
>
> Hi,all
> 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。
> FLink sql有什么方案实现吗?
>
> 感谢您的回复