开发者社区> 问答> 正文

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

我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。

FLink sql有什么方案实现吗?*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-07 15:17:08 2139 0
1 条回答
写回答
取消 提交回答
  • 我们也遇到过类似场景。

    如果你的数据里面有事件时间,可以写个udf来判断下,如果事件时间-当前时间 小于某个阈值,可以sleep一下。

    如果没有事件时间,那就不太好直接搞了,我们是自己搞了一个延迟维表,就是保证每条数据进到维表join算子后等固定时间后再去join。*来自志愿者整理的flink邮件归档

    2021-12-07 16:21:33
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载