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

2. Flink快速上手

news 2026/2/8 19:46:21

文章目录

  • 1. 环境准备
    • 1.1 系统环境
    • 1.2 安装配置Java 8和Scala 2.12
    • 1.3 使用集成开发环境IntelliJ IDEA
    • 1.4 安装插件
  • 2. 创建项目
    • 2.1 创建工程
      • 2.1.1 创建Maven项目
      • 2.1.2 设置项目基本信息
      • 2.1.3 生成项目基本框架
    • 2.2 添加项目依赖
      • 2.2.1 添加Flink相关依赖
      • 2.2.2 添加slf4j-nop依赖
      • 2.2.3 刷新项目依赖
  • 3. 编写代码
    • 3.1 准备工作
      • 3.1.1更名目录
      • 3.1.2 添加scala-sdk到项目
      • 3.1.3 查看是否可以创建Scala类
      • 3.1.4 设置源目录与测试源目录
      • 3.1.5 准备数据文件
      • 3.1.6 词频统计思路
      • 3.1.7 创建包
    • 3.2 批处理
      • 3.2.1 创建单例对象
      • 3.2.2 运行程序，查看结果
      • 3.2.3 注意事项
    • 3.3 流处理
      • 3.3.1 流数据概念
      • 3.3.2 读取文件
        • 3.3.2.1 创建单例对象
        • 3.3.2.2 运行程序，查看结果
      • 3.3.3 读取文本流
        • 3.3.3.1 创建单例对象
        • 3.3.3.2 主机上启动nc
        • 3.3.3.3 启动词频统计程序
        • 3.3.3.4 主机上利用nc发送数据
        • 3.3.3.5 在控制台查看结果
  • 4. 总结

在这里插入图片描述

1. 环境准备

大家好，今天我们将一起学习如何快速上手Apache Flink。首先，我们需要准备一下环境。

1.1 系统环境

请确保您的系统环境为Windows 10。

1.2 安装配置Java 8和Scala 2.12

在开始之前，请确认您已经安装了Java 8和Scala 2.12。您可以通过命令行查看Java和Scala的版本。

java -version
scala -version

1.3 使用集成开发环境IntelliJ IDEA

我们推荐使用IntelliJ IDEA 2020.1版本作为我们的集成开发环境。

1.4 安装插件

在IDEA中，我们需要安装以下插件：

  • Maven插件
  • Git插件
  • Scala插件

这些插件将帮

相关文章：

2. Flink快速上手

文章目录 1. 环境准备1.1 系统环境1.2 安装配置Java 8和Scala 2.121.3 使用集成开发环境IntelliJ IDEA1.4 安装插件2. 创建项目2.1 创建工程2.1.1 创建Maven项目2.1.2 设置项目基本信息2.1.3 生成项目基本框架2.2 添加项目依赖2.2.1 添加Flink相关依赖2.2.2 添加slf4j-nop依赖2…...

编程日记 2024/10/30 13:56:46

Java-I/O框架06：常见字符编码、字符流抽象类

视频链接：16.16 字符流抽象类_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV1Tz4y1X7H7?spm_id_from333.788.videopod.episodes&vd_sourceb5775c3a4ea16a5306db9c7c1c1486b5&p16 1.常见字符编码 IOS-8859-1收录了除ASCII外，还包括西欧…...

编程日记 2024/10/30 13:55:46

计算机网络-MSTP的基础概念

前面我们大致了解了MSTP的由来，是为了解决STP/RSTP只有一根生成树导致的VLAN流量负载分担与次优路径问题，了解MSTP采用实例映射VLAN的方式实现多实例生成树，MSTP有很多的理论概念需要知道，其实与其它的知识一样理论复杂配置还好的…...

编程日记 2024/10/30 13:54:45

P1037 [NOIP2002 普及组] 产生数

[NOIP2002 普及组] 产生数 题目描述 给出一个整数 n n n 和 k k k 个变换规则。 规则： 一位数可变换成另一个一位数。规则的右部不能为零。 例如： n 234 , k 2 n234,k2 n234,k2。有以下两个规则： 2 ⟶ 5 2\longrightarrow 5 2⟶5。 …...

编程日记 2024/10/30 13:51:42

【分布式知识】分布式对象存储组件-Minio

文章目录 什么是minio核心特点：使用场景：开发者工具：社区和支持： 核心概念什么是对象存储？MinIO 如何确定对对象的访问权限？我可以在存储桶内按文件夹结构组织对象吗？如何备份和恢复 MinIO 上的…...

编程日记 2024/10/30 13:50:41

跨平台开发支付组件，实现支付宝支付

效果图： custom-payment ： 在生成预付订单之后页面中需要弹出一个弹层，弹层中展示的内容为支付方式（渠道），由用户选择一种支付方式进行支付。 该弹层组件是以扩展组件 uni-popup 为核心的，关于…...

编程日记 2024/10/30 13:48:38

API 接口：为电商行业高效发展注入强劲动力

一、动力之源：API 接口在电商中的角色剖析 在电商行业的广袤版图中，API 接口宛如一台强劲的发动机，是推动其高效发展的核心动力来源。它不再仅仅是一个技术工具，而是成为了连接电商各个环节的 “神经系统”，使得信息、…...

编程日记 2024/10/30 13:46:35

Golang的跨平台开发

Golang的跨平台开发 一、Golang跨平台开发概述 语言是一种开源的编程语言，由Google开发，广泛应用于云计算和网络编程领域。Golang具有并发性好、性能优异、内存管理自动化等特点，因此备受开发者青睐。其中，Golang的跨平台特性使得…...

编程日记 2024/10/30 13:44:33

txt数据转为pdf格式并使用base64解密输出

使用该方法请注意&#xff1a;因为此方法使用了base64解密&#xff0c;需要保证txt中的数据首先用了base64加密&#xff0c;如果只是普通的二进制数据&#xff0c;该方法并不适用 第一步 <dependency><groupId>org.apache.pdfbox</groupId><artifactId&…...

编程日记 2024/10/30 13:43:32

鸿蒙开发-状态+判断+循环

​&#x1f308;个人主页&#xff1a;前端青山 &#x1f525;系列专栏&#xff1a;鸿蒙开发篇 &#x1f516;人终将被年少不可得之物困其一生 依旧青山,本期给大家带来鸿蒙开发篇专栏内容:鸿蒙开发-状态判断循环 目录 1.状态1原始类型 2.引用类型 2.判断 3.循环 1.基本使用…...

编程日记 2024/10/30 13:42:31

基于SSM网上招投标管理系统的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;用户管理&#xff0c;招标者管理&#xff0c;专家管理&#xff0c;项目分类管理&#xff0c;招标项目管理&#xff0c;系统管理 前台账号功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0…...

编程日记 2024/10/30 13:41:30

「C/C++」C++ 设计模式 之 单例模式（Singleton）

✨博客主页何曾参静谧的博客&#x1f4cc;文章专栏「C/C」C/C程序设计&#x1f4da;全部专栏「VS」Visual Studio「C/C」C/C程序设计「UG/NX」BlockUI集合「Win」Windows程序设计「DSA」数据结构与算法「UG/NX」NX二次开发「QT」QT5程序设计「File」数据文件格式「PK」Parasoli…...

编程日记 2024/10/30 13:39:28

WPF的行为(Behavior)

WPF&#xff08;Windows Presentation Foundation&#xff09;是微软.NET框架中用于构建Windows客户端应用程序的UI框架。它提供了一种声明性的方式来定义用户界面&#xff0c;并且支持MVVM&#xff08;Model-View-ViewModel&#xff09;设计模式。 在WPF中&#xff0c;“行为…...

编程日记 2024/10/30 13:38:26

SpringBoot框架：闲一品交易平台的新突破

摘 要 随着科学技术的飞速发展&#xff0c;社会的方方面面、各行各业都在努力与现代的先进技术接轨&#xff0c;通过科技手段来提高自身的优势&#xff0c;闲一品交易平台当然也不能排除在外。闲一品交易平台是以实际运用为开发背景&#xff0c;运用软件工程原理和开发方法&…...

编程日记 2024/10/30 13:36:21

关于AI绘画 | Stable Diffusion 技术专栏推荐文章

AI绘画 | Stable Diffusion 技术专栏推荐文章 引言 随着人工智能技术的发展&#xff0c;AI绘画逐渐成为艺术创作的新潮流。在众多的AI绘画工具中&#xff0c;Stable Diffusion因其强大的功能和易用性受到了广泛的关注。本文将详细介绍由“泰山AI”创建的技术专栏“AI绘画 | S…...

编程日记 2024/10/30 13:34:17

Oracle 第13章：事务处理

在数据库管理系统&#xff08;DBMS&#xff09;中&#xff0c;事务处理是一个非常重要的概念&#xff0c;它确保了数据的一致性和可靠性。下面我将解释事务的概念与特性&#xff0c;并讨论如何进行事务管理。 事务的概念与特性 事务是指作为一个工作单元的一组有序的SQL操作。…...

编程日记 2024/10/30 13:33:16

String的长度有限，而我对你的思念却无限延伸

公主请阅 1. 为什么学习string类&#xff1f;2. string类的常用接口2.1 string类对象的常见构造2.1.1 string 2.2 operator[]2.3 迭代器2.4 auto自动推导数据类型2.5 范围for2.6 迭代器第二层2.7 size和length获取字符串的长度2.8 max_size 获取这个字符串能设置的最大长度2.9 …...

编程日记 2024/10/30 13:30:13

二叉树的后序遍历

给你一棵二叉树的根节点 root &#xff0c;返回其节点值的 后序遍历 。 示例 1&#xff1a; 输入&#xff1a;root [1,null,2,3] 输出&#xff1a;[3,2,1] 解释&#xff1a; 示例 2&#xff1a; 输入&#xff1a;root [1,2,3,4,5,null,8,null,null,6,7,9] 输出&#xf…...

编程日记 2024/10/30 13:28:10

Nvidia未来的Blackwell Ultra GPU将更名为B300系列

据TrendForce报道&#xff0c;英伟达&#xff08;Nvidia&#xff09;计划将其Blackwell Ultra产品线重新命名为B300系列&#xff0c;以更好地与即将推出的B100和B200产品进行区分。Blackwell Ultra系列将是一个具有更高性能的升级版本。但据报道&#xff0c;这种升级后的内存配…...

编程日记 2024/10/30 13:27:08

BUUCTF靶场Misc练习

在BUUCTF中&#xff0c;你需要留意各种关于涉及 flag{ } 的信息。只要找的到flag&#xff0c;你就算成功。本文记录我刷BUUCTF的Misc类方法和个人感悟。 Misc第一题 签到 题解在题目中&#xff0c;如图所示 flag是 flag{buu_ctf} 第二题 &#xff08;题目如图所示&#xff…...

编程日记 2024/10/30 13:23:59

RestClient

什么是RestClient RestClient 是 Elasticsearch 官方提供的 Java 低级 REST 客户端&#xff0c;它允许HTTP与Elasticsearch 集群通信&#xff0c;而无需处理 JSON 序列化/反序列化等底层细节。它是 Elasticsearch Java API 客户端的基础。 RestClient 主要特点 轻量级&#xff…...

编程新知 2025/11/30 15:33:36

【Python】 -- 趣味代码 - 小恐龙游戏

文章目录 文章目录 00 小恐龙游戏程序设计框架代码结构和功能游戏流程总结01 小恐龙游戏程序设计02 百度网盘地址00 小恐龙游戏程序设计框架 这段代码是一个基于 Pygame 的简易跑酷游戏的完整实现，玩家控制一个角色（龙）躲避障碍物（仙人掌和乌鸦）。以下是代码的详细介绍：…...

编程新知 2026/1/31 13:59:37

IGP（Interior Gateway Protocol，内部网关协议）

IGP&#xff08;Interior Gateway Protocol&#xff0c;内部网关协议&#xff09; 是一种用于在一个自治系统&#xff08;AS&#xff09;内部传递路由信息的路由协议&#xff0c;主要用于在一个组织或机构的内部网络中决定数据包的最佳路径。与用于自治系统之间通信的 EGP&…...

编程新知 2025/10/12 11:54:26

镜像里切换为普通用户

如果你登录远程虚拟机默认就是 root 用户&#xff0c;但你不希望用 root 权限运行 ns-3&#xff08;这是对的&#xff0c;ns3 工具会拒绝 root&#xff09;&#xff0c;你可以按以下方法创建一个 非 root 用户账号 并切换到它运行 ns-3。 一次性解决方案&#xff1a;创建非 roo…...

编程新知 2025/9/11 11:00:29

MODBUS TCP转CANopen 技术赋能高效协同作业

在现代工业自动化领域&#xff0c;MODBUS TCP和CANopen两种通讯协议因其稳定性和高效性被广泛应用于各种设备和系统中。而随着科技的不断进步&#xff0c;这两种通讯协议也正在被逐步融合&#xff0c;形成了一种新型的通讯方式——开疆智能MODBUS TCP转CANopen网关KJ-TCPC-CANP…...

编程新知 2026/2/6 9:48:02

Python爬虫（二）：爬虫完整流程

爬虫完整流程详解&#xff08;7大核心步骤实战技巧&#xff09; 一、爬虫完整工作流程 以下是爬虫开发的完整流程&#xff0c;我将结合具体技术点和实战经验展开说明&#xff1a; 1. 目标分析与前期准备 网站技术分析&#xff1a; 使用浏览器开发者工具&#xff08;F12&…...

编程新知 2025/10/19 5:48:51

数据库分批入库

今天在工作中&#xff0c;遇到一个问题&#xff0c;就是分批查询的时候&#xff0c;由于批次过大导致出现了一些问题&#xff0c;一下是问题描述和解决方案&#xff1a; 示例&#xff1a; // 假设已有数据列表 dataList 和 PreparedStatement pstmt int batchSize 1000; // …...

编程新知 2026/1/8 11:38:36

为什么要创建 Vue 实例

核心原因：Vue 需要一个「控制中心」来驱动整个应用 你可以把 Vue 实例想象成你应用的**「大脑」或「引擎」。它负责协调模板、数据、逻辑和行为，将它们变成一个活的、可交互的应用**。没有这个实例，你的代码只是一堆静态的 HTML、JavaScript 变量和函数，无法「活」起来。 …...

编程新知 2026/1/3 7:21:08

给网站添加live2d看板娘

给网站添加live2d看板娘 参考文献&#xff1a; stevenjoezhang/live2d-widget: 把萌萌哒的看板娘抱回家 (ノ≧∇≦)ノ | Live2D widget for web platformEikanya/Live2d-model: Live2d model collectionzenghongtu/live2d-model-assets 前言 网站环境如下&#xff0c;文章也主…...

编程新知 2026/2/1 4:23:19

WPF八大法则：告别模态窗口卡顿

⚙️ 核心问题&#xff1a;阻塞式模态窗口的缺陷 原始代码中ShowDialog()会阻塞UI线程&#xff0c;导致后续逻辑无法执行&#xff1a; var result modalWindow.ShowDialog(); // 线程阻塞 ProcessResult(result); // 必须等待窗口关闭根本问题&#xff1a…...

编程新知 2026/1/26 17:26:03