开发者社区> 问答> 正文

flink 维表关联

flink的kafka流表与hbase维表关联,维表后面有变动的话,如何将之前关联过的数据进行更新? *来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-08 11:29:44 639 0
1 条回答
写回答
取消 提交回答
  • 我个人觉得可以把join的条件和流对应的数据存放在mapstate中,每次维表的缓存更新数据之后,去mapstate中查询,如果存在对应的KV,将新关联后的数据下发;

    不过这样state会占用很大的内存,需要主意state的清理c*来自志愿者整理的flink邮件归档

    2021-12-08 13:55:01
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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