现在有这样的需求flinksql可以做吗?

现在有这样的需求flinksql可以做吗?某张表有逻辑删除字段,想筛选掉未逻辑删除的数据,就加了逻辑删除字段为空的判断。之后发现逻辑删除的记录直接被过滤掉了,没有根据主键覆盖旧的记录导致数据不准确,有没有方案解决呀。

展开
收起
三分钟热度的鱼 2023-08-22 15:52:51 59 分享 版权
1 条回答
写回答
取消 提交回答
  • 再加一张表。你肯定得保证所有的数据都进入到目的表,然后再在处理的时候过滤逻辑删除。此回答整理自钉群“实时计算Flink产品交流群”

    2023-08-22 16:13:34
    赞同 展开评论

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

还有其他疑问?
咨询AI助理