当前位置： 首页 > news >正文

flink 键控状态（keyed state）

news 文章来源：https://blog.csdn.net/cobracanary/article/details/129284771 2024/11/16 18:47:48

github开源项目flink-note的笔记。本博客的实现代码都写在项目的flink-state/src/main/java/state/keyed/KeyedStateDemo.java文件中。
项目github地址： github

1. flink键控状态

flink键控状态是作用与flink KeyedStream上的，也就是说需要将DataStream先进行keyby之后才能使用。键控状态会为每个key维护一份状态。flink支持五种键控状态，分别是：

  • ValueState: 维护一个值的状态，比方说我们要统计每个用户的购买次数，那么就先将流按照用户id进行keyby，然后维护一个类型为Integer的ValueState。 这个值可以被update(T)更新，使用T value()进行获取。
  • ListState ：维护一个list的状态，可以使用 add(T) 、 addAll(List)、update(List)来更新列表状态中的值，使用Iterable get()来获取list中的值。
  • ReducingState 与ListState类似，只是将所有值都reduce出一个结果。
  • AggregatingState<IN, OUT> 与上面类似
  • MapState<UK, UV> 与上面类似

2. 键控状态的使用

在KeyedStateDemo.java中，我们实现了如下的功能：
我们从socket中读取用户的行为日志ÿ

相关文章：

flink 键控状态（keyed state）

github开源项目flink-note的笔记。本博客的实现代码都写在项目的flink-state/src/main/java/state/keyed/KeyedStateDemo.java文件中。 项目github地址： github 1. flink键控状态 flink键控状态是作用与flink KeyedStream上的，也就是说需要将DataStream先进行keyby之后才能使…...

编程日记 2023/3/2 12:58:10

【ChatGPT】sqlachmey 多表连表查询语句

感受下科技带来的魅力&#xff0c;这篇文章是通过ChatGPT自动生成的&#xff0c;不得不说技术强大!!! 在SQLAlchemy中进行多表连接查询可以使用join()方法或join()函数&#xff0c;具体用法如下&#xff1a; join()方法 join()方法可以在SQLAlchemy ORM中的查询中使用。假设…...

编程日记 2023/3/2 12:57:06

win11 系统登录问题，PIN 设置问题

我的电脑配置是华为MateBook X Pro 12&#xff0c;i7处理器&#xff0c;16G&#xff0c;1T&#xff0c;win11 系统通过微软账户登录&#xff0c;下午一直登录不进去&#xff0c;网络能连外网&#xff0c;分析应该是连微软服务器不行。连续登录几十次&#xff0c;偶尔可能有一次…...

编程日记 2023/3/2 12:55:59

数据结构六大排序

1.插入排序 思路&#xff1a; 从第一个元素开始认为是有序的&#xff0c;去一个元素tem从有序序列从后往前扫描&#xff0c;如果该元素大于tem&#xff0c;将该元素一刀下一位&#xff0c;循环步骤3知道找到有序序列中小于等于的元素将tem插入到该元素后&#xff0c;如果已排序…...

编程日记 2023/3/2 12:54:54

快速生成QR码的方法：教你变成QR Code Master

目录 简介: 具体实现步骤&#xff1a; 一、可以使用Python中的qrcode和tkinter模块来生成QR码。以下是一个简单的例子&#xff0c;演示如何在Tkinter窗口中获取用户输入并使用qrcode生成QR码。 1&#xff09;首先需要安装qrcode模块&#xff0c;可以使用以下命令在终端或命令…...

编程日记 2023/3/2 12:52:42

tensorflow1.14.0安装教程--保姆级

//方法不止一种&#xff0c;下面仅展示一种。 注&#xff1a;本人电脑为win11&#xff0c;anaconda的python版本为3.9&#xff0c;但tensorflow需要python版本为3.7&#xff0c;所以下面主要阐述将python版本改为3.7后的安装过程以及常遇到的问题。 1.首先电脑安装好anaconda…...

编程日记 2023/3/2 12:51:37

AcWing算法提高课-3.1.3香甜的黄油

宣传一下算法提高课整理 <— CSDN个人主页&#xff1a;更好的阅读体验 <— 题目传送门点这里 题目描述 农夫John发现了做出全威斯康辛州最甜的黄油的方法&#xff1a;糖。 把糖放在一片牧场上&#xff0c;他知道 N 只奶牛会过来舔它&#xff0c;这样就能做出能卖好价…...

编程日记 2023/3/2 12:50:32

私库搭建1：Nexus 安装 Docker 版

本文内容以语雀为准 文档 https://hub.docker.com/r/sonatype/nexus3Docker 安装&#xff1a;https://www.yuque.com/xuxiaowei-com-cn/gitlab-k8s/docker-install 安装 创建文件夹 由于 Nexus 的数据可能会很大&#xff0c;比如&#xff1a;作为 Docker、Maven 私库时&…...

编程日记 2023/3/2 12:49:26

LeetCode-面试题 05.02. 二进制数转字符串【数学，字符串，位运算】

LeetCode-面试题 05.02. 二进制数转字符串【数学&#xff0c;字符串&#xff0c;位运算】题目描述&#xff1a;解题思路一&#xff1a;简单暴力。小数点后面的二进制&#xff0c;now首先从0.5开始之和每次除以2。然后依次判断当前数是否大于now&#xff0c;是则答案加1。若等于…...

编程日记 2023/3/2 12:48:21

pandas: 三种算法实现递归分析Excel中各列相关性

目录 前言 目的 思路 代码实现 1. 循环遍历整个SDGs列&#xff0c;两两拿到数据 2. 调用pandas库函数直接进行分析 完整源码 运行效果 总结 前言 博主之前刚刚被学弟邀请参与了2023美赛&#xff0c;这也是第一次正式接触数学建模竞赛&#xff0c;现在已经提交等待结果…...

编程日记 2023/3/2 12:47:13

【Python百日进阶-Web开发-Vue3】Day543 - Vue3 商城后台 03：登录页面初建

文章目录 一、创建登录页面 login.vue二、登录页面响应式处理，以适应不同大小的屏幕2.1 element-plus 的layout布局中关于响应式的说明2.2 修改login.vue文件2.2.1 :lg=16 大于1200px 横排 2:12.2.2 :md=12 大于992小于1200px 横排 1:12.2.3 小于992 竖排三、引入Element-plus…...

编程日记 2023/3/2 12:46:08

python画直方图，刻画数据分布

先展示效果 准备一维数据 n 个数据元素计算最大值&#xff0c;最小值、均值、标准差、以及直方图分组 import numpy as np data list() for i in range(640):data.append(np.random.normal(1)) print(data)z np.histogram(data, bins64) print(list(z[0])) ### 对应 x 轴数据…...

编程日记 2023/3/2 12:45:01

几何学小课堂：非欧几何（广义相对论采用黎曼几何作为数学工具）【学数学关键是要学会在什么情况下，知道使用什么工具。】

文章目录 引言I 非欧几何1.1 黎曼几何1.2 共形几何1.3 罗氏几何II 黎曼几何的应用2.1 广义相对论2.2 超弦III 理解不同的几何体系的共存3.1 更扎实的欧氏几何3.2 殊途同归引言 公理有错会得到两种情况： 如果某一条自己设定的新公理和现有的公理相矛盾，那么相应的知识体系就建…...

编程日记 2023/3/2 12:43:56

Ubuntu配置静态IP的方法

Ubuntu配置静态IP的方法前言一、查看虚机分配的网卡IP二、查看网卡的网关IP三、配置静态IP1.配置IPv4地址2.执行netplan apply使改动生效3.配置的网卡未生效&#xff0c;修改50-cloud-init.yaml文件解决4.测试vlan网络通信总结前言 Ubuntu18.04 欧拉环境 vlan网络支持ipv6场景…...

编程日记 2023/3/2 12:42:48

90%的人都不算会爬虫，这才是真正的技术，从0到高手的进阶

很多人以为学会了urlib模块和xpath等几个解析库&#xff0c;学了Selenium就会算精通爬虫了&#xff0c;但到外面想靠爬虫技术接点私活&#xff0c;才发现寸步难行。 龙叔我做了近20年的程序员&#xff0c;今天就告诉你&#xff0c;真正的爬虫高手应该学哪些东西&#xff0c;就…...

编程日记 2023/3/2 12:41:41

排序之损失函数List-wise loss(系列3)

排序系列篇&#xff1a; 排序之指标集锦(系列1)原创 排序之损失函数pair-wise loss(系列2)排序之损失函数List-wise loss(系列3) 最早的关于list-wise的文章发表在Learning to Rank: From Pairwise Approach to Listwise Approach中&#xff0c;后面陆陆续续出了各种变形&#…...

编程日记 2023/3/2 12:40:35

js对象和原型、原型链的关系

JS的原型、原型链一直是比较难理解的内容&#xff0c;不少初学者甚至有一定经验的老鸟都不一定能完全说清楚&#xff0c;更多的"很可能"是一知半解&#xff0c;而这部分内容又是JS的核心内容&#xff0c;想要技术进阶的话肯定不能对这个概念一知半解&#xff0c;碰到…...

编程日记 2023/3/2 12:39:26

【SpringBoot高级篇】SpringBoot集成Sharding-JDBC分库分表

【SpringBoot高级篇】SpringBoot集成Sharding-JDBC分库分表Apache ShardingSphere分库分表分库分表的方式垂直切分垂直分表垂直分库水平切分水平分库水平分表分库分表带来的问题分库分表中间件Sharding-JDBCsharding-jdbc实现水平分表sharding-jdbc实现水平分库sharding-jdbc实…...

编程日记 2023/3/2 12:38:22

Shell特殊字符

shell语言&#xff0c;一些字符是有特殊意义的。 根据作用分为几种特殊符号 一、空白 shell调用函数&#xff0c;不像c语言那样用把参数放到括号里&#xff0c;用逗号分隔。而是用空格作为参数之间&#xff0c;参数与函数名之间的分隔符。 换行符也是特殊字符。换行符用作一条命…...

编程日记 2023/3/2 12:37:15

【计算机二级python】综合题目

计算机二级python真题 文章目录计算机二级python真题一、德国工业战略规划二、德国工业战略规划 第一问三、德国工业战略规划 第二问一、德国工业战略规划 描述:在右侧答题模板中修改代码&#xff0c;删除代码中的横线&#xff0c;填写代码&#xff0c;完成考试答案。‪‬‪‬…...

编程日记 2023/3/2 12:36:08

字节直播leader面

设计评论系统&#xff08;缓存怎么做&#xff09; mysql是否有主从延迟&#xff0c;如何解决 mysql有主从延迟 主从延迟主要因为mysql主从同步的机制&#xff0c;mysql有三种同步机制 同步复制&#xff1a;事务线程等待所有从库复制成功响应异步复制&#xff1a;事务不等待…...

编程日记 2023/3/2 12:33:55

PIC 单片机的时钟

注意&#xff1a;本文的内容无法保证绝对精确&#xff0c;后续可能会做改动&#xff0c;只是自己的笔记。这里的资料均源自数据手册本身。PIC18系列单片机的参考时钟可以选择三个基础时钟源&#xff1a;Primary Clock, OSC1 or OSC2,Secondary Clock,Inner clock.时钟源分为两个…...

编程日记 2023/3/2 12:32:51

【数据结构】关于二叉树你所应该知道的数学秘密

目录 1.什么是二叉树&#xff08;可以跳过 目录跳转&#xff09; 2.特殊的二叉树&#xff08;满二叉树/完全二叉树&#xff09; 2.1 基础知识 2.2 满二叉树 2.3 完全二叉树 3.二叉树的数学奥秘&#xff08;主体&#xff09; 3.1 高度与节点个数 3.2* 度 4.运用二叉树的…...

编程日记 2023/3/2 12:31:46

哈希表题目：猜数字游戏

文章目录题目标题和出处难度题目描述要求示例数据范围解法一思路和算法代码复杂度分析解法二思路和算法代码复杂度分析题目 标题和出处 标题&#xff1a;猜数字游戏 出处&#xff1a;299. 猜数字游戏 难度 4 级 题目描述 要求 你在和朋友一起玩猜数字&#xff08;Bulls…...

编程日记 2023/3/2 12:29:31

项目请求地址自动加上了本地ip的解决方式

一般情况下来说都是一些粗心大意的问题导致的 场景一&#xff1a;少加了/ 场景二&#xff1a;前后多加了空格 场景三&#xff1a;拼接地址错误![...

编程日记 2023/3/2 12:28:26

Vue3 企业级项目实战：项目须知与课程约定

本节内容很重要&#xff0c;希望大家能够耐心看完。 Vue3 企业级项目实战 - 程序员十三 - 掘金小册Vue3 Element Plus Spring Boot 企业级项目开发&#xff0c;升职加薪&#xff0c;快人一步。。「Vue3 企业级项目实战」由程序员十三撰写&#xff0c;2744人购买https://s.ju…...

编程日记 2023/3/2 12:27:21

传导EMI抑制-Π型滤波器设计

1 传导电磁干扰简介 在开关电源中&#xff0c;开关管周期性的通断会产生周期性的电流突变&#xff08;di/dt&#xff09;和电压突变(dv/dt)&#xff0c;周期性的电流变化和电压变化则会导致电磁干扰的产生。 图1所示为Buck电路的电流变化&#xff0c;在Buck电路中上管电流和下…...

编程日记 2023/3/2 12:26:16

如何在excel中创建斐波那契数列

斐波那契数列&#xff08;Fibonacci sequence&#xff09;&#xff0c;又称黄金分割数列&#xff0c;因数学家莱昂纳多斐波那契&#xff08;Leonardo Fibonacci&#xff09;以兔子繁殖为例子而引入&#xff0c;故又称为“兔子数列”&#xff0c;指的是这样一个数列&#xff1a;…...

编程日记 2023/3/2 12:25:09

遮挡检测--基于角度的遮挡检测方法

文章目录1基于角度的遮挡检测方法2遮挡检测遍历方法2.1方法1--自适应径向扫描方法2.2方法2--螺旋扫描法参考1基于角度的遮挡检测方法 在基于角度的方法中&#xff0c;通过依次分析DSM中沿径向方向的投影光线的角度来识别遮挡。定义α\alphaα角&#xff1a;DSM三维点与相机中心…...

编程日记 2023/3/2 12:24:04

【luogu CF1098D】Eels（结论）

Eels 题目链接&#xff1a;luogu CF1098D 题目大意 有一个可重集&#xff0c;每次操作会放进去一个数或者取出一个数。 然后每次操作完之后&#xff0c;问你对这个集合进行操作&#xff0c;每次选出两个数 a,b 加起来合并回去&#xff0c;直到集合中只剩一个数&#xff0c;要…...

编程日记 2023/3/2 12:22:56

好看的做地图分析图的网站/2022最新小学生新闻

我新注册的coder.cn域名怎么样&#xff1f; 呵呵。准备用来开发一些开发人员的东东。还可以开设一些二级域名的服务供大家使用&#xff0c;例如 http://blog.coder.cn http://domain.coder.cn http://bbs.coder.cn http://gbook.coder.cn http://dotnet.coder.cn http://java.c…...

编程日记 2024/11/16 16:31:21

衡阳微信网站开发/软件开发培训

MCU是一个专业术语&#xff0c;如果不是行业人士&#xff0c;其实并不是很清楚MCU究竟是什么。其实MCU就是单片机&#xff0c;英文是Microcontroller Unit&#xff0c;MCU其实也可以理解为简单版本的CPU&#xff0c;MCU目前多应用于消费电子和通讯、汽车电子、工业、医疗设备等…...

编程日记 2024/11/16 14:15:44

企业网上推广方式/西安seo霸屏

LeetCode 456. 132模式 难度 中等 给定一个整数序列&#xff1a;a1, a2, …, an&#xff0c;一个132模式的子序列ai, aj, ak被定义为&#xff1a;当i < j < k时&#xff0c;ai < ak < aj。设计一个算法&#xff0c;当给定有n个数字的序列时&#xff0c;验证这个…...

编程日记 2024/11/16 9:45:46

徐州金网网站建设/中国营销传播网官网

自建数据集实现车标识别 使用YOLOv5 YOLOv3算法训练的模型 支持奔驰 宝马 奥迪 别克 丰田等常见车标 效果还是不错的&#xff0c;同时使用pyqt开发的简易可视化界面...

编程日记 2024/11/16 2:44:56

做网站贵/东莞网站到首页排名

免费帮大家发布招聘需求&#xff0c;如有需要可在微信上与我联系~地点&#xff1a;南京岗位&#xff1a;数据分析 & 数据开发经验要求&#xff1a;本科3年左右&#xff0c;研究生1年左右薪资&#xff1a;13-18K技能要求&#xff1a;数据开发【熟悉Java&#xff0c;了解大数…...

编程日记 2024/11/15 23:19:25

做标识的网站 知乎/seo检测

对 Linux 新手非常有用的 20 个命令 http://www.oschina.net/translate/useful-linux-commands-for-newbies 对 Linux 中级用户非常有用的 20 个命令 http://www.oschina.net/translate/20-advanced-commands-for-linux-experts 对 Linux 专家非常有用的 20 个命令 http://www.…...

编程日记 2024/11/15 21:58:45