2. Flink快速上手
文章目录
- 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…...
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外，还包括西欧…...
计算机网络-MSTP的基础概念
前面我们大致了解了MSTP的由来，是为了解决STP/RSTP只有一根生成树导致的VLAN流量负载分担与次优路径问题，了解MSTP采用实例映射VLAN的方式实现多实例生成树，MSTP有很多的理论概念需要知道，其实与其它的知识一样理论复杂配置还好的…...
P1037 [NOIP2002 普及组] 产生数
[NOIP2002 普及组] 产生数 题目描述 给出一个整数 n n n 和 k k k 个变换规则。 规则： 一位数可变换成另一个一位数。规则的右部不能为零。 例如： n 234 , k 2 n234,k2 n234,k2。有以下两个规则： 2 ⟶ 5 2\longrightarrow 5 2⟶5。 …...
【分布式知识】分布式对象存储组件-Minio
文章目录 什么是minio核心特点：使用场景：开发者工具：社区和支持： 核心概念什么是对象存储？MinIO 如何确定对对象的访问权限？我可以在存储桶内按文件夹结构组织对象吗？如何备份和恢复 MinIO 上的…...
跨平台开发支付组件，实现支付宝支付
效果图： custom-payment ： 在生成预付订单之后页面中需要弹出一个弹层，弹层中展示的内容为支付方式（渠道），由用户选择一种支付方式进行支付。 该弹层组件是以扩展组件 uni-popup 为核心的，关于…...
API 接口：为电商行业高效发展注入强劲动力
一、动力之源：API 接口在电商中的角色剖析 在电商行业的广袤版图中，API 接口宛如一台强劲的发动机，是推动其高效发展的核心动力来源。它不再仅仅是一个技术工具，而是成为了连接电商各个环节的 “神经系统”，使得信息、…...
Golang的跨平台开发
Golang的跨平台开发 一、Golang跨平台开发概述 语言是一种开源的编程语言，由Google开发，广泛应用于云计算和网络编程领域。Golang具有并发性好、性能优异、内存管理自动化等特点，因此备受开发者青睐。其中，Golang的跨平台特性使得…...
txt数据转为pdf格式并使用base64解密输出
使用该方法请注意：因为此方法使用了base64解密，需要保证txt中的数据首先用了base64加密，如果只是普通的二进制数据，该方法并不适用 第一步 <dependency><groupId>org.apache.pdfbox</groupId><artifactId&…...
鸿蒙开发-状态+判断+循环
🌈个人主页：前端青山 🔥系列专栏：鸿蒙开发篇 🔖人终将被年少不可得之物困其一生 依旧青山,本期给大家带来鸿蒙开发篇专栏内容:鸿蒙开发-状态判断循环 目录 1.状态1原始类型 2.引用类型 2.判断 3.循环 1.基本使用…...
基于SSM网上招投标管理系统的设计
管理员账户功能包括：系统首页，个人中心，用户管理，招标者管理，专家管理，项目分类管理，招标项目管理，系统管理 前台账号功能包括：系统首页，个人中心࿰…...
「C/C++」C++ 设计模式 之 单例模式（Singleton）
✨博客主页何曾参静谧的博客📌文章专栏「C/C」C/C程序设计📚全部专栏「VS」Visual Studio「C/C」C/C程序设计「UG/NX」BlockUI集合「Win」Windows程序设计「DSA」数据结构与算法「UG/NX」NX二次开发「QT」QT5程序设计「File」数据文件格式「PK」Parasoli…...
WPF的行为(Behavior)
WPF（Windows Presentation Foundation）是微软.NET框架中用于构建Windows客户端应用程序的UI框架。它提供了一种声明性的方式来定义用户界面，并且支持MVVM（Model-View-ViewModel）设计模式。 在WPF中，“行为…...
SpringBoot框架：闲一品交易平台的新突破
摘 要 随着科学技术的飞速发展，社会的方方面面、各行各业都在努力与现代的先进技术接轨，通过科技手段来提高自身的优势，闲一品交易平台当然也不能排除在外。闲一品交易平台是以实际运用为开发背景，运用软件工程原理和开发方法&…...
关于AI绘画 | Stable Diffusion 技术专栏推荐文章
AI绘画 | Stable Diffusion 技术专栏推荐文章 引言 随着人工智能技术的发展，AI绘画逐渐成为艺术创作的新潮流。在众多的AI绘画工具中，Stable Diffusion因其强大的功能和易用性受到了广泛的关注。本文将详细介绍由“泰山AI”创建的技术专栏“AI绘画 | S…...
Oracle 第13章：事务处理
在数据库管理系统（DBMS）中，事务处理是一个非常重要的概念，它确保了数据的一致性和可靠性。下面我将解释事务的概念与特性，并讨论如何进行事务管理。 事务的概念与特性 事务是指作为一个工作单元的一组有序的SQL操作。…...
String的长度有限，而我对你的思念却无限延伸
公主请阅 1. 为什么学习string类？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 …...
二叉树的后序遍历
给你一棵二叉树的根节点 root ，返回其节点值的 后序遍历 。 示例 1： 输入：root [1,null,2,3] 输出：[3,2,1] 解释： 示例 2： 输入：root [1,2,3,4,5,null,8,null,null,6,7,9] 输出…...
Nvidia未来的Blackwell Ultra GPU将更名为B300系列
据TrendForce报道，英伟达（Nvidia）计划将其Blackwell Ultra产品线重新命名为B300系列，以更好地与即将推出的B100和B200产品进行区分。Blackwell Ultra系列将是一个具有更高性能的升级版本。但据报道，这种升级后的内存配…...
BUUCTF靶场Misc练习
在BUUCTF中，你需要留意各种关于涉及 flag{ } 的信息。只要找的到flag，你就算成功。本文记录我刷BUUCTF的Misc类方法和个人感悟。 Misc第一题 签到 题解在题目中，如图所示 flag是 flag{buu_ctf} 第二题 （题目如图所示ÿ…...
线程与协程
1. 线程与协程 1.1. “函数调用级别”的切换、上下文切换 1. 函数调用级别的切换 “函数调用级别的切换”是指：像函数调用/返回一样轻量地完成任务切换。 举例说明： 当你在程序中写一个函数调用： funcA() 然后 funcA 执行完后返回&…...
1688商品列表API与其他数据源的对接思路
将1688商品列表API与其他数据源对接时，需结合业务场景设计数据流转链路，重点关注数据格式兼容性、接口调用频率控制及数据一致性维护。以下是具体对接思路及关键技术点： 一、核心对接场景与目标 商品数据同步 场景：将1688商品信息…...
Linux简单的操作
ls ls 查看当前目录 ll 查看详细内容 ls -a 查看所有的内容 ls --help 查看方法文档 pwd pwd 查看当前路径 cd cd 转路径 cd .. 转上一级路径 cd 名 转换路径 …...
【磁盘】每天掌握一个Linux命令 - iostat
目录 【磁盘】每天掌握一个Linux命令 - iostat工具概述安装方式核心功能基础用法进阶操作实战案例面试题场景生产场景 注意事项 【磁盘】每天掌握一个Linux命令 - iostat 工具概述 iostat（I/O Statistics）是Linux系统下用于监视系统输入输出设备和CPU使…...
如何在看板中有效管理突发紧急任务
在看板中有效管理突发紧急任务需要：设立专门的紧急任务通道、重新调整任务优先级、保持适度的WIP（Work-in-Progress）弹性、优化任务处理流程、提高团队应对突发情况的敏捷性。其中，设立专门的紧急任务通道尤为重要，这能…...
生成 Git SSH 证书
🔑 1. 生成 SSH 密钥对 在终端（Windows 使用 Git Bash，Mac/Linux 使用 Terminal）执行命令： ssh-keygen -t rsa -b 4096 -C "your_emailexample.com" 参数说明： -t rsa&#x…...
Springcloud：Eureka 高可用集群搭建实战（服务注册与发现的底层原理与避坑指南）
引言：为什么 Eureka 依然是存量系统的核心？ 尽管 Nacos 等新注册中心崛起，但金融、电力等保守行业仍有大量系统运行在 Eureka 上。理解其高可用设计与自我保护机制，是保障分布式系统稳定的必修课。本文将手把手带你搭建生产级 Eur…...
令牌桶 滑动窗口-＞限流 分布式信号量-＞限并发的原理 lua脚本分析介绍
文章目录 前言限流限制并发的实际理解限流令牌桶代码实现结果分析令牌桶lua的模拟实现原理总结： 滑动窗口代码实现结果分析lua脚本原理解析 限并发分布式信号量代码实现结果分析lua脚本实现原理 双注解去实现限流 并发结果分析： 实际业务去理解体会统一注…...
【Oracle】分区表
个人主页：Guiat 归属专栏：Oracle 文章目录 1. 分区表基础概述1.1 分区表的概念与优势1.2 分区类型概览1.3 分区表的工作原理 2. 范围分区 (RANGE Partitioning)2.1 基础范围分区2.1.1 按日期范围分区2.1.2 按数值范围分区 2.2 间隔分区 (INTERVAL Partit…...
分布式增量爬虫实现方案
之前我们在讨论的是分布式爬虫如何实现增量爬取。增量爬虫的目标是只爬取新产生或发生变化的页面，避免重复抓取，以节省资源和时间。 在分布式环境下，增量爬虫的实现需要考虑多个爬虫节点之间的协调和去重。 另一种思路：将增量判…...