flinksql 回撤流中主键发生变更的影响(group by中的值发生改变)

1 什么是回撤流

这篇文章主要谈论一个场景,简单来说:
首先我们来简单的说一下什么是回撤流,以及回撤流的底层原理,举个例子:
在这里插入图片描述

这个说的不是很清晰 ,其实倒数第二个图当作输出 比较好看出来,再bank 这一条来之后,数据结果是
hello 1
world 1
bank 1
这个时候 又来了一条hello,刚刚已经下发的hello 1 这个结果就不对了,就需要降这条结果撤回,也就是撤回一条 hello 1 下发一条 hello 2。简单的说 这就是回撤流。

我们用最常见的 ,用的最多的kafka来举例回撤流 大家可能就明白了

  • 来了一条hello数据 下发一条
    [+I] hello 1
  • 又来了一条hello,上一条撤回
    [-U] hello 1
  • 下发一条
    [

最近更新

  1. TCP协议是安全的吗?

    2024-06-05 20:36:09       19 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-06-05 20:36:09       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-06-05 20:36:09       20 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-06-05 20:36:09       20 阅读

热门阅读

  1. leetcode 802.找到最终的安全状态

    2024-06-05 20:36:09       9 阅读
  2. 摸鱼大数据——Hive调优10-12

    2024-06-05 20:36:09       9 阅读
  3. mysql-集群-二进制部署

    2024-06-05 20:36:09       4 阅读
  4. 45、Flink 的 Process Function 详解

    2024-06-05 20:36:09       9 阅读
  5. SpringBoot历史版本信息

    2024-06-05 20:36:09       10 阅读
  6. 【实用技巧】Unity的Text组件实用技巧

    2024-06-05 20:36:09       8 阅读
  7. GPT-4o:人工智能新纪元的启航者

    2024-06-05 20:36:09       8 阅读
  8. 如何评价GPT-4o?(要点精简)

    2024-06-05 20:36:09       8 阅读
  9. 排序---快速排序

    2024-06-05 20:36:09       7 阅读
  10. Python没什么?深度解析Python的无限可能与挑战

    2024-06-05 20:36:09       9 阅读
  11. React.forwardRef 使用

    2024-06-05 20:36:09       9 阅读
  12. h5相机功能

    2024-06-05 20:36:09       8 阅读