Flink的DataStream状态管理
目录
键控数据流（Keyed DataStream）
键控状态（Keyed State）
值状态（ValueState）
列表状态（ListState）
归约状态（ReducingState）
聚合状态（AggregatingState）
映射状态（MapState）
状态生存时间(TTL)
算子状态（Operator State）
广播状态（Broadcast State）
实现CheckpointedFunction 使用算子状态
对于DataStream来说，状态主要分为如下两类：
（1）键控状态（keyed state）
（2）算子状态（Operator State）
说键控状态之前，不得不提键控数据流。
键控数据流（Keyed DataStream）
如果希望使用键控状态（keyed state），首先需要在数据流上指定一个键，该键用于对状态（以及流本身中的记录）进行分区。您可以在数据流上使用Java/Scala API中的keyBy(KeySelector)或Python API中的key_by(KeySelector)来指定键。使用该方法后将产生一个键控流KeyedStream，它允许使用键控状态的算子。
键选择器函数（key selector function）接受一条记录作为输入，并返回该记录的键。键可以是任何类型，并且必须从确定性计算中得到。
Flink的数据模型不是基于键值对的。因此，不需要将数据集类型物理地打包到键和值中。键是“虚拟的”：它们被定义为实际数据上的函数，以指导分组算子。
相关文章：
Flink的DataStream状态管理
目录 键控数据流（Keyed DataStream） 键控状态（Keyed State） 值状态（ValueState） 列表状态（ListState） 归约状态（ReducingState） 聚合状态（AggregatingState） 映射状态（MapState） 状态生存时间(TTL) 算子状态（Operator State） 广播状态（Broadcast S…...
Daiqile SQL注入绕过
上源码。 <?php header("Content-type: text/html; charsetutf-8"); require db.inc.php;function dhtmlspecialchars($string) {if (is_array($string)) {foreach ($string as $key > $val) {$string[$key] dhtmlspecialchars($val);}}else {$string str_…...
用Python轻松移除PDF中的注释
PDF文档因其跨平台的兼容性和格式稳定性而备受青睐。然而，随着文档在不同用户间的流转，累积的注释可能会变得杂乱无章，甚至包含敏感或过时的信息，这不仅影响了文档的清晰度和专业性，还可能引发隐私风险。因此ÿ…...
51单片机—串口
一、 串口基本认知 串行接口简称串口，也称串行通信接口或串行通讯接口（通常指COM接口），是采用串行通信方 式的扩展接口。串行接口（Serial Interface）是指数据一位一位地顺序传送。其特点是通信线路简 单&a…...
vue 通过 this.$refs 创建方法i向子组件传参让子组件更新
在Vue中，this.$refs主要用于访问子组件的实例或者DOM元素。通过this.$refs，你可以调用子组件的方法或者访问其数据属性，从而实现子组件的更新。以下是一些使用this.$refs向子组件传参并触发更新的常见方法： 1. 直接调用子组件的方…...
Java设计模式以及代理模式
一、设计模式 1.JAVA六大设计原则 JAVA设计模式提供六个基本原则，分别是： 开闭原则(OCP) - The Open-Closed Principle单一职责原则(SRP) - Single Responsibility Principle里氏替换原则(LSP) - Liskov Substitution Principle依赖倒置原则(DIP) - D…...
Elasticsearch 索引库管理：查询、修改与删除
Elasticsearch 是一个高度可扩展的开源全文搜索和分析引擎，它允许用户通过 RESTful API 进行数据的索引、搜索、更新和管理。在 Elasticsearch 中，索引库（Index）是存储数据的基本单元。本文将介绍如何查询、修改和删除 Elasticsea…...
视频大怎么压缩小？分享3种视频压缩方法
视频大怎么压缩小？视频文件过大时，压缩视频不仅能帮助我们节省宝贵的存储空间，使其更容易在有限容量的设备中保存，还能显著提升传输效率，特别是在网络条件有限或需要快速分享视频内容的场合。通过专业的压缩工具&#…...
springboot项目搭建集成 redis/跨域/远程请求
目录 一，创建maven项目 1，左上角file > new > maven project 2，next 到 创建 Group id 和 Artifact id编辑编辑 二，配置springboot 1，配置pom文件， 2，创建启动类 3ÿ…...
lvs详解及实例配置
目录 1.什么是负载均衡 1.1为什么用负载均衡 1.2.负载均衡类型 1.2.1.四层负载均衡 1.2.2.七层负载均衡 1.3 四层和七层的区别 2.LVS介绍 2.1LVS 的优势与不足 2.2LVS 核心组件和专业术语 3.ipvsadm命令 4.LVS集群中的增删改 4.1.管理集群服务中的增删改 4.2.管理集…...
DAY41-动态规划-买卖股票
LeetCode121. 买卖股票的最佳时机 public int maxProfit(int[] prices) {//dp数组含义：0为持有该股票，1为不持有该股票int[][] dp new int[prices.length][2];dp[0][0]-prices[0];dp[0][1]0;for(int i1;i<prices.length;i) {dp[i][0]Math.max(dp[i-…...
【C#】StringComparer
什么是“文化” 在 .NET 中，“文化”（Culture）指的是与语言、地区、和区域设置相关的特定信息集合。这些信息包括了日期和时间的格式、数字的表示方式、货币符号、字符串比较规则等等。文化的概念在软件开发中特别重要，因为应用程…...
阿里云服务器远程登录问题解决指南
前言 在使用阿里云服务器时，可能会遇到无法通过密码进行远程登录的情况。这种情况通常是因为操作系统默认禁用了密码登录功能。本文将介绍如何解决这一问题，确保能够顺利地通过密码进行远程登录。 问题描述 当尝试通过Workbench进行密码登录时&#x…...
Datawhale X 魔搭 AI夏令营（2024第四期）AIGC方向 学习笔记
粗谈 这一期是使用可图lora微调进行文生图任务的比赛 文生图也算是跨模态了，输入Prompt文本，输出图片。Prompt很重要，分为prompts和negative prompts。可以指导结果图片的生成。 lora可以参考我上期夏令营的文章:Datawhale AI 夏令营&…...
VScode前端环境搭建
前言 VScode是企业中最常用的前端开发工具，本文描述如何利用VScode搭建前端开发环境 一、安装VScode 下载Vscode 点击前往下载页面 安装 安装时一直点击下一步即可 二、环境配置 1）更改语言 点击拓展搜索Chinese后下载第一个，下载完后…...
Python自动化测试之selenium - 元素定位
元素定位 元素定位就是通过元素的信息或者元素层级结构来定位元素。当定位到了重复的属性，默认会定位到第一个标签。 id定位 - find_element_by_id 同一个html页面中id值是唯一的。 模拟在百度输入框中输入想要查找的内容 python 代码解读 复制代码 from sel…...
深入探索 npm cache clean --force：清理 npm 缓存的艺术
npm 是 JavaScript 编程语言的包管理器，它是 Node.js 运行环境的默认包管理器。npm 提供了一个丰富的生态系统，包括数以百万计的可重用代码包。然而，随着时间的推移，npm 的缓存可能会变得庞大，影响性能或导致一些奇怪的…...
如何看待“低代码”开发平台的兴起？
如何看待“低代码”开发平台的兴起？ 近年来，“低代码”开发平台如雨后春笋般涌现，承诺让非专业人士也能快速构建应用程序。这种新兴技术正在挑战传统软件开发模式，引发了IT行业的广泛讨论。低代码平台是提高效率的利器࿰…...
自动控制——过阻尼、欠阻尼、临界阻尼及无阻尼
自动控制——过阻尼、欠阻尼、临界阻尼及无阻尼 引言 在自动控制系统和振动分析中，系统的阻尼特性对于系统的动态响应至关重要。阻尼决定了系统在受到扰动或输入信号后，如何恢复到稳定状态。本文将详细介绍过阻尼（overdamped）、…...
从AlphaGo到AlphaPong：AI乒乓球机器人将如何改变乒乓球竞技？
在人工智能领域，谷歌DeepMind的AlphaGo曾以其超凡的围棋能力震惊了世界。而如今，DeepMind又将其技术延伸到了乒乓球领域，推出了乒乓球机器人，被网友戏称为“AlphaPong”。这一机器人使用ABB的IRB1100机械手臂，能够与普…...
解决Ubuntu22.04 VMware失败的问题 ubuntu入门之二十八
现象1 打开VMware失败 Ubuntu升级之后打开VMware上报需要安装vmmon和vmnet，点击确认后如下提示 最终上报fail 解决方法 内核升级导致，需要在新内核下重新下载编译安装 查看版本 $ vmware -v VMware Workstation 17.5.1 build-23298084$ lsb_release…...
【CSS position 属性】static、relative、fixed、absolute 、sticky详细介绍，多层嵌套定位示例
文章目录 ★ position 的五种类型及基本用法 ★ 一、position 属性概述 二、position 的五种类型详解（初学者版） 1. static（默认值） 2. relative（相对定位） 3. absolute（绝对定位） 4. fixed（固定定位） 5. sticky（粘性定位） 三、定位元素的层级关系（z-i…...
【ROS】Nav2源码之nav2_behavior_tree-行为树节点列表
1、行为树节点分类 在 Nav2（Navigation2）的行为树框架中，行为树节点插件按照功能分为 Action（动作节点）、Condition（条件节点）、Control（控制节点） 和 Decorator（装饰节点） 四类。 1.1 动作节点 Action 执行具体的机器人操作或任务，直接与硬件、传感器或外部系统…...
视频字幕质量评估的大规模细粒度基准
大家读完觉得有帮助记得关注和点赞！！！ 摘要 视频字幕在文本到视频生成任务中起着至关重要的作用，因为它们的质量直接影响所生成视频的语义连贯性和视觉保真度。尽管大型视觉-语言模型（VLMs）在字幕生成方面…...
微信小程序云开发平台MySQL的连接方式
注：微信小程序云开发平台指的是腾讯云开发 先给结论：微信小程序云开发平台的MySQL，无法通过获取数据库连接信息的方式进行连接，连接只能通过云开发的SDK连接，具体要参考官方文档： 为什么？ 因为…...
中关于正整数输入的校验规则)
Element Plus 表单(el-form)中关于正整数输入的校验规则
目录 1 单个正整数输入1.1 模板1.2 校验规则 2 两个正整数输入（联动）2.1 模板2.2 校验规则2.3 CSS 1 单个正整数输入 1.1 模板 <el-formref"formRef":model"formData":rules"formRules"label-width"150px"…...
ip子接口配置及删除
配置永久生效的子接口，2个IP 都可以登录你这一台服务器。重启不失效。 永久的 [应用] vi /etc/sysconfig/network-scripts/ifcfg-eth0修改文件内内容 TYPE"Ethernet" BOOTPROTO"none" NAME"eth0" DEVICE"eth0" ONBOOT&q…...
使用Spring AI和MCP协议构建图片搜索服务
目录 使用Spring AI和MCP协议构建图片搜索服务 引言 技术栈概览 项目架构设计 架构图 服务端开发 1. 创建Spring Boot项目 2. 实现图片搜索工具 3. 配置传输模式 Stdio模式（本地调用） SSE模式（远程调用） 4. 注册工具提…...
Netty从入门到进阶（二）
二、Netty入门 1. 概述 1.1 Netty是什么 Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients. Netty是一个异步的、基于事件驱动的网络应用框架，用于…...
实战三：开发网页端界面完成黑白视频转为彩色视频
一、需求描述 设计一个简单的视频上色应用，用户可以通过网页界面上传黑白视频，系统会自动将其转换为彩色视频。整个过程对用户来说非常简单直观，不需要了解技术细节。 效果图 二、实现思路 总体思路： 用户通过Gradio界面上…...