开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请教个问题,通过flink sql能获取到某条数据update之前跟之后的状态吗?类似datastr

请教个问题,通过flink sql能获取到某条数据update之前跟之后的状态吗?类似datastream api里面json字符串的before跟after

展开
收起
雪哥哥 2022-11-27 10:40:33 476 0
1 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    在 Flink SQL 中,可以通过使用 Temporal Table Join 实现类似数据更新前后状态的查询。

    Temporal Table Join 是一种将维度表和事实表连接起来的方式,在连接时可以指定某个时间点或时间范围,从而获取在该时间点或时间范围内维度表和事实表的关联记录。

    对于您的问题,可以将需要查询的数据作为事实表,将其之前的状态保存在一个另外的表中作为维度表。这样,在执行 Temporal Table Join 时,就可以将之前的状态与当前的状态进行比较,实现类似数据更新前后状态的查询。

    具体操作可以参考官方文档中的 Temporal Table Join 部分。

    2023-04-14 20:29:46
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

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