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

Flink DataStream API 编程指南

news 2026/5/21 8:20:32

（对于Flink的开发，建议使用Java，Scala的支持未来会被移除）

DataStream是什么

DataStream API得名于DataStream这个Java类，可以将它们视为可以包含重复项的不可变数据集合。该数据可以是有限的，也可以是无限的，用于处理它们的API是相同的。

DataStream在用法上和普通的Java集合类似，但在一些关键方面有很大的不同。它们是不可变的，这意味着一旦创建了它们，就不能添加或删除元素。你可以在上面执行各种transformations操作。

通过在Flink程序中添加数据源，可以创建初始的DataStream。然后你可以由此派生出新的流，并使用map、filter等API方法将它们组合起来。

剖析Flink程序整体过程

Flink程序就是对DataStream的各种转换（transformations）的过程，每个程序由相同的基本部分组成：

  1. 获取执行环境
  2. 加载/创建初始数据
  3. 指定此数据的转换
  4. 指定将计算结果的存放位置
  5. 触发程序执行

下面以java api的方式来说明以上过程：

1）获取执行环境

可以通过 StreamExecutionEnvironment 的方法来获得：

相关文章：

Flink DataStream API 编程指南

（对于Flink的开发，建议使用Java，Scala的支持未来会被移除） DataStream是什么 DataStream API得名于DataStream这个Java类，可以将它们视为可以包含重复项的不可变数据集合。该数据可以是有限的，也可以是无限的，用于处理它们的API是相同的。 DataStream在用法上和普通的…...

编程日记 2024/12/22 19:39:57

tryhackme-Pre Security-HTTP in Detail（HTTP的详细内容）

任务一：What is HTTP(S)?（什么是http（s）） 1.What is HTTP? (HyperText Transfer Protocol)（什么是 HTTP？（超文本传输协议）） http是你查看网站的时候遵循的…...

编程日记 2024/12/22 19:38:54

探索 Plotly：一个强大的交互式数据可视化库

探索 Plotly：一个强大的交互式数据可视化库 数据可视化是数据分析过程中不可或缺的一部分，它能帮助我们更直观地理解数据，发现数据中的趋势和规律。在众多可视化库中，Plotly 是一个非常强大的工具，它以其交互式、易用…...

编程日记 2024/12/22 19:35:51

Oracle 查询表占用空间（表大小）的方法

目录 概述方法一：使用 dbms_space 包方法二：查询 dba_extents 视图方法三：查询 dba_segments 视图总结 1. 概述 在Oracle数据库管理中，了解特定表或索引所占用的空间对于性能调优、存储规划以及资源分配至关重要。本文档介绍了三…...

编程日记 2024/12/22 19:33:49

机器人国际会议IROS论文latex模板

机器人国际会议IROS论文latex模板 文档 root.tex 可以配置为 US Letter 纸或 A4。请注意以下重要行：\documentclass[letterpaper, 10 pt, Conference]{ieeeconf} % 如果需要 a4paper，请注释掉此行%\documentclass[a4paper, 10pt, Conference]{ieeeconf} …...

编程日记 2024/12/22 19:23:39

雪泥鸿爪和屈指可数

paw这个单词，表示“爪或手”，是一个和hoof相对的单词： hoof n.(马等动物的)蹄paw n.爪子；(动物的)爪；(人的)手 v.挠，抓；动手动脚 所以，当你理解了 paw 和 hoof 是相对的概念时&…...

编程日记 2024/12/22 19:22:38

2024年度个人总结

一转眼已经2024年度最后一个月了，今年基本没有在CSDN发布内容，包括其他平台（B站），倒是在其他地方（我的个人网站和V2EX）发布一些零碎的东西，主要是因为今年换了工作后太累了&#xff…...

编程日记 2024/12/22 19:20:36

ChatGPT接口测试用例生成的流程

通常，使用ChatGPT生成接口测试用例的流程可以分为以下关键步骤。 收集接口信息 收集接口的相关文档和信息，如接口名称、请求方法、请求参数、返回结果等。这些是ChatGPT生成测试用例需要的输入信息。 这一步骤的重要性不可忽视，因为它为Chat…...

编程日记 2024/12/22 19:10:29

【读书笔记】《论语别裁》真人和假人

一、内容摘要 在《论语别裁》第01章中，作者探讨了“真人”与“假人”的概念，借鉴于庄子的思想，强调真正有道德修养且懂得人生真谛的人被称为“真人”，而那些未达到道德最高标准的人则称为“假人。孔子所提倡的“学”不仅仅是书本…...

编程日记 2024/12/22 19:06:25

JS字符串方法汇总

String.anchor //创建一个带有名称的 <a> 元素字符串 //已弃用 let str test str.anchor(name) //<a name"name">test</a>String.at let str 1234567 str.at(0) //1 str.at(1) //2 str.at(-1) //7 str.at(-2) //6String.big //已弃用 let …...

编程日记 2024/12/22 19:05:24

CentOs7使用yum安装docker

安装docker 一、安装docker依赖 sudo yum install -y yum-utils device-mapper-persistent-data lvm2二、添加软件源信息 sudo yum-config-manager --add-repo https://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo sudo sed -i sdownload.docker.commirrors.…...

编程日记 2024/12/22 19:01:16

蓝桥杯刷题——day8

蓝桥杯刷题——day8 题目一题干解题思路代码 题目二题干解题思路代码 题目一 题干 N 架飞机准备降落到某个只有一条跑道的机场。其中第i架飞机在 Ti时刻到达机场上空&#xff0c;到达时它的剩余油料还可以继续盘旋 Di个单位时间&#xff0c;即它最早可以于 Ti时刻开始降落&am…...

编程日记 2024/12/22 18:56:11

如何使用 WebAssembly 扩展后端应用

1. WebAssembly 简介 随着互联网的发展&#xff0c;越来越多的应用借助 Javascript 转到了 Web 端&#xff0c;但人们也发现&#xff0c;随着移动互联网的兴起&#xff0c;需要把大量的应用迁移到手机端&#xff0c;随着手端的应用逻辑越来越复杂&#xff0c;Javascript 的解析…...

编程日记 2024/12/22 18:52:08

BaseCTF_web_week3

复读机 输入的东西会在下方显示出来&#xff0c;wp说是简单的SSTI&#xff0c;这里来学习一下SSTI SSTI模板注入 根据My4n师傅的《超详细SSTI模板注入漏洞原理讲解_ssti注入-CSDN博客》写的 用户的输入返回时会经过一个模板渲染&#xff0c;SSTI漏洞就是用户插入了可以破坏模板…...

编程日记 2024/12/22 18:49:04

模型数据算法概论

模型数据算法是一类使用数据来构建、优化或训练数学模型的算法&#xff0c;常用于数据科学、机器学习和人工智能领域。它们的核心目标是从数据中提取模式或关系&#xff0c;以便在预测、分类或优化任务中应用。以下是一个简要的概述&#xff1a; 1. 模型 模型是用来描述数据特…...

编程日记 2024/12/22 18:47:03

什么是3DEXPERIENCE SOLIDWORKS，它有哪些角色和功能？

将业界领先的 SOLIDWORKS 3D CAD 解决方案连接到基于单一云端产品开发环境 3DEXPERIENCE 平台。您的团队、数据和流程全部连接到一个平台进行高效的协作工作&#xff0c;从而能快速的做出更好的决策。 目 录&#xff1a; ★ 1 什么是3DEXPERIENCE SOLIDWORKS ★ 2 3DEXPERIE…...

编程日记 2024/12/22 18:46:01

Sigrity System SI Parallel Bus Analysis模式进行DDR3仿真分析-传输线模型

Sigrity System SI Parallel Bus Analysis模式进行DDR3仿真分析-传输线模型 Sigrity System SI Parallel Bus Analysis模式提供了简易的已搭建好的模板，方便用户直接在模板上替换数据文件进行仿真分析，下面介绍pba_simple_em模板的使用，具体操作如下 双击启动System SI启动界…...

编程日记 2024/12/22 18:45:01

MacOS下PostIn安装配置指南

PostIn是一款开源免费的接口管理工具&#xff0c; 下面介绍私有部署版本的MacOS下安装与配置。私有部署版本更适合有严格数据安全要求的企业&#xff0c;实现对数据和系统的完全控制。 &#xfeff; &#xfeff; 1、MacOS服务端安装 Mac安装包下载地址&#xff1a;下载Mac安…...

编程日记 2024/12/22 18:43:59

【Leetcode 每日一题】2545. 根据第 K 场考试的分数排序

问题背景 班里有 m m m 位学生&#xff0c;共计划组织 n n n 场考试。给你一个下标从 0 0 0 开始、大小为 m n m \times n mn 的整数矩阵 s c o r e score score&#xff0c;其中每一行对应一位学生&#xff0c;而 s c o r e [ i ] [ j ] score[i][j] score[i][j] 表示…...

编程日记 2024/12/22 18:42:58

一文速通 IIC I2C子系统驱动 通信协议原理 硬件 时序 深度剖析

本文作为一个引入&#xff0c;作用是让读者理解熟知IIC协议关键内容&#xff0c;结合实际手册内容&#xff0c;深度解析协议本质&#xff0c;作为后续嵌入式linux驱动IIC子系统的一个铺垫。 目录 1. 硬件连接 2. IIC传输时序 2.1.写操作 2.2.读操作 2.3.I2C信号 3.IIC协议…...

编程日记 2024/12/22 18:41:57

Omdia：2025年第一季度，东南亚手机市场下滑9%，但厂商利润率正在改善

Omdia最新研究显示&#xff0c;2026年第一季度东南亚智能手机市场出货量同比下降 9%&#xff0c;总量为 2160万部。然而&#xff0c;市场最值得关注的并非出货量下滑&#xff0c;而是平均售价&#xff08;ASP&#xff09;的变化&#xff1a;受存储成本上涨影响&#xff0c;2026…...

编程新知 2026/5/21 6:54:00

ARM SVE架构LD1H指令详解与性能优化

1. ARM SVE架构与LD1H指令概述在Armv8.2架构引入的可扩展向量扩展(Scalable Vector Extension, SVE)彻底改变了传统SIMD指令集的设计理念。与固定128位或256位宽度的NEON指令不同&#xff0c;SVE采用向量长度不可知(Vector Length Agnostic, VLA)编程模型&#xff0c;允许同一套…...

编程新知 2026/5/21 6:08:51

从环境变量到Git Bash：给Plink找个‘家’，让你的遗传数据分析命令随处可跑

从环境变量到Git Bash&#xff1a;打造遗传数据分析的高效工作流 在遗传数据分析的日常工作中&#xff0c;Plink作为核心工具几乎出现在每个分析流程中。但许多研究者都会遇到这样的困扰&#xff1a;每次打开新的终端窗口&#xff0c;要么需要反复输入冗长的路径&#xff0c;要…...

编程新知 2026/5/21 5:55:43

硬件开发、智能硬件与硬件系统：从概念到产品的完整技术解析

1. 项目概述&#xff1a;从“黑盒子”到“白盒子”的认知跃迁在科技行业摸爬滚打十几年&#xff0c;我见过太多对“硬件”这个词的误解。有人觉得硬件就是电脑、手机这些看得见摸得着的“铁疙瘩”&#xff1b;有人觉得智能硬件就是给传统设备加个Wi-Fi模块&#xff1b;还有人觉…...

编程新知 2026/5/21 5:47:38

ScrollMonitor：JavaScript滚动监控库的完整指南 - 如何高效监听元素进入视口

ScrollMonitor&#xff1a;JavaScript滚动监控库的完整指南 - 如何高效监听元素进入视口 【免费下载链接】scrollmonitor A simple and fast API to monitor elements as you scroll 项目地址: https://gitcode.com/gh_mirrors/sc/scrollmonitor ScrollMonitor 是一款轻…...

编程新知 2026/5/21 4:59:45

dvwa靶场Dom型xss通关

​ ​黑盒操作 LOW 一、这是一个选项框内容&#xff0c;发现输入内容会直接改变选项内容&#xff0c;查看代码后发现js代码 // 这是通过字符串拼接创建出页面显示选项 if (document.location.href.indexOf("default") > 0) { // 拼接document.location.href.in…...

编程新知 2026/5/21 4:09:24

别再只问哪个大模型更强了，2026年真正决定AI Agent上限的，是向量引擎

别再只问哪个大模型更强了&#xff0c;2026年真正决定AI Agent上限的&#xff0c;是向量引擎 这两年做AI的人&#xff0c;最容易掉进一个坑。 每天盯着模型榜单看。 今天这个模型会写代码了。 明天那个模型会看视频了。 后天又有一个模型说自己推理能力更强了。 看久了以后&…...

编程新知 2026/5/21 3:42:09

18V/4A同步降压转换器：MPQ8632GLE-4的COT控制与快速瞬态响应解析

MPQ8632GLE-4&#xff1a;4A/18V 同步降压转换器的紧凑型电源解决方案在通信设备、分布式电源系统以及服务器主板等应用中&#xff0c;电源管理单元需要在小面积内实现高效率的电压转换&#xff0c;同时保持良好的瞬态响应。传统的 PWM 控制器往往需要复杂的环路补偿设计&#…...

编程新知 2026/5/21 2:18:20

避坑指南：在VisDrone上训练YOLOv7时，我遇到的过拟合与数据增强那些坑

VisDroneYOLOv7实战避坑手册&#xff1a;从数据增强到过拟合的深度调优 第一次在VisDrone数据集上跑YOLOv7时&#xff0c;我盯着验证集mAP0.5从0.4缓慢爬到0.5就停滞不前&#xff0c;而训练集指标却一路飙升到0.9——典型的过拟合现象。更讽刺的是&#xff0c;当我尝试将图片切…...

编程新知 2026/5/21 0:50:34

AD9361配置避坑指南：从UART调试到FLASH固化的全流程实战（Verilog源码分析）

AD9361纯逻辑配置实战&#xff1a;从UART调试到FLASH固化的工程化解决方案 在无线通信系统开发中&#xff0c;AD9361作为一款高度集成的射频收发器&#xff0c;其配置方式直接关系到项目开发效率。对于需要脱离处理器依赖、追求极致实时性的场景&#xff0c;纯FPGA逻辑(PL)配置…...

编程新知 2026/5/20 23:59:58