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

2024-06-02 07:28
文章标签 改变 主键 发生 变更 影响 group flinksql 流中 回撤

本文主要是介绍flinksql 回撤流中主键发生变更的影响（group by中的值发生改变），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

flinksql 回撤流中，主键发生变更的影响

  • 1 什么是回撤流
  • 2 主键变更场景
  • 3 实践中发现的比较好的的实时数仓架构

1 什么是回撤流

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

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

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

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

其实所谓的回撤，是下发了两条数据，告诉下游 上一条我废弃了&#x

这篇关于flinksql 回撤流中主键发生变更的影响（group by中的值发生改变）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1023319。

相关文章

SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

查看原文>>>全流程SWAP农业模型数据制备、敏感性分析及气候变化影响实践技术应用 SWAP模型是由荷兰瓦赫宁根大学开发的先进农作物模型，它综合考虑了土壤-水分-大气以及植被间的相互作用；是一种描述作物生长过程的一种机理性作物生长模型。它不但运用Richard方程，使其能够精确的模拟土壤中水分的运动，而且耦合了WOFOST作物模型使作物的生长描述更为科学。 本文让更多的科研人员和农业工作者
阅读更多...
matlab读取NC文件（含group）

matlab读取NC文件（含group）

matlab读取NC文件（含group）： NC文件数据结构： 代码： % 打开 NetCDF 文件filename = 'your_file.nc'; % 替换为你的文件名% 使用 netcdf.open 函数打开文件ncid = netcdf.open(filename, 'NC_NOWRITE');% 查看文件中的组% 假设我们想读取名为 "group1" 的组groupName
阅读更多...
当你输入一个网址后都发生什么

当你输入一个网址后都发生什么

原文:http://igoro.com/archive/what-really-happens-when-you-navigate-to-a-url/  作为一个软件开发者，你一定会对网络应用如何工作有一个完整的层次化的认知，同样这里也包括这些应用所用到的技术：像浏览器，HTTP，HTML，网络服务器，需求处理等等。 本文将更深入的研究当你输入一个网址的时候，后台到底发生了一件件什么样的事～
阅读更多...
Oracle主键和外键详解及实用技巧

Oracle主键和外键详解及实用技巧

在 Oracle 数据库中，主键（Primary Key）和外键（Foreign Key）用于维护数据库表之间的数据完整性。 1. 主键（Primary Key） 主键是一列或多列，能够唯一标识表中的每一行。表中只能有一个主键，并且主键列不能为空（即 NOT NULL）。 特性： 唯一性：主键中的每一个值都是唯一的，不能重复。非空性：主键列不能包含 NULL 值。索引：Oracle 自动为
阅读更多...
AI辅助编程里的 Atom Group 的概念和使用

AI辅助编程里的 Atom Group 的概念和使用

背景 在我们实际的开发当中，一个需求往往会涉及到多个文件修改，而需求也往往有相似性。 举个例子，我经常需要在 auto-coder中需要添加命令行参数，通常是这样的： /coding 添加一个新的命令行参数 --chat_model 默认值为空 实际上这个需求涉及到以下文件列表： /Users/allwefantasy/projects/auto-coder/src/autocoder/auto
阅读更多...
Qt中window frame的影响

Qt中window frame的影响

window frame 在创建图形化界面的时候，会创建窗口主体，上面会多出一条，周围多次一圈细边，这就叫window frame窗口框架，这是操作系统自带的。 这个对geometry的一些属性有一定影响，主要体现在Qt坐标系体系： 窗口当中包含一个按钮，这个按钮的坐标系是以父元素为参考，那么这个参考是widget本体作为参考，还是window frame作为参考，这两种参考体系都存在
阅读更多...
react笔记 8-18 事件 方法 定义方法 获取/改变数据 传值

react笔记 8-18 事件 方法 定义方法 获取/改变数据 传值

1、定义方法并绑定 class News extends React.Component {constructor(props) {super(props)this.state = {msg:'home组件'}}run(){alert("我是一个run") //方法写在类中}render() {return (<div><h2>{this.state.msg}</h2><button onCli
阅读更多...
实现Web页面内容动态改变的dhtml操作

实现Web页面内容动态改变的dhtml操作

阅读更多...
日本某地发生了一件谋杀案，警察通过排查确定杀人凶手必为4个 嫌疑犯的一个。以下为4个嫌疑犯的供词。

日本某地发生了一件谋杀案，警察通过排查确定杀人凶手必为4个 嫌疑犯的一个。以下为4个嫌疑犯的供词。

日本某地发生了一件谋杀案，警察通过排查确定杀人凶手必为4个 嫌疑犯的一个。以下为4个嫌疑犯的供词。 A说：不是我。 B说：是C。 C说：是D。 D说：C在胡说 已知3个人说了真话，1个人说的是假话。 现在请根据这些信息，写一个程序来确定到底谁是凶手。  static void Main()         {             int killer = 0;             fo
阅读更多...
【前端】animation动画以及利用vue制作简单的透明度改变动画，包含vue生命周期实现

【前端】animation动画以及利用vue制作简单的透明度改变动画，包含vue生命周期实现

一. 问题描述 想做一个文字透明度从1到0然后再从0到1的css动画。 二. 代码写法 2.1 animation写法 2.1.1 animation属性key 2.1.2 代码展示 <!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><meta name="viewport" content="width=de
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2