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

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解密输出

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

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

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

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

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

「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…...

WPF的行为(Behavior)

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

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

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

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

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

Oracle 第13章:事务处理

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

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 …...

二叉树的后序遍历

给你一棵二叉树的根节点 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…...

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

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

BUUCTF靶场Misc练习

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

LettR编辑器光标增强插件:提升代码编辑效率的智能导航方案

1. 项目概述&#xff1a;一个为LettR编辑器量身定制的光标增强插件如果你和我一样&#xff0c;日常重度依赖代码编辑器&#xff0c;那你一定对光标这个看似不起眼的小东西又爱又恨。爱的是&#xff0c;它是我们与代码世界交互的核心&#xff1b;恨的是&#xff0c;当代码文件越…...

福特技术复兴:用户体验整合如何重塑汽车行业竞争格局

1. 福特的技术复兴之路&#xff1a;一次深度拆解十年前&#xff0c;当大多数传统汽车制造商还在为金融危机后的生存而挣扎时&#xff0c;福特汽车做出了一个在当时看来颇具前瞻性的决定&#xff1a;将技术&#xff0c;而非仅仅是马力或造型&#xff0c;作为品牌复兴的核心驱动力…...

半导体行业数据解析:销售额与资本支出双高增长背后的逻辑

1. 行业数据深度解析&#xff1a;半导体销售额与资本支出的双高增长最近和几个在晶圆厂和设计公司工作的朋友聊天&#xff0c;大家不约而同地提到了一个词&#xff1a;“忙疯了”。订单排到明年&#xff0c;产线24小时连轴转&#xff0c;连带着上游的设备商和材料供应商都跟着“…...

MediaCreationTool.bat:解决Windows安装媒体创建痛点的灵活工具

MediaCreationTool.bat&#xff1a;解决Windows安装媒体创建痛点的灵活工具 【免费下载链接】MediaCreationTool.bat Universal MCT wrapper script for all Windows 10/11 versions from 1507 to 21H2! 项目地址: https://gitcode.com/gh_mirrors/me/MediaCreationTool.bat …...

开源协作平台Octopal:整合Git、文档与任务的项目管理利器

1. 项目概述&#xff1a;一个为开发者量身定制的开源协作平台如果你是一名开发者&#xff0c;或者是一个小型技术团队的负责人&#xff0c;那么你一定对这样的场景不陌生&#xff1a;手头有几个并行的项目&#xff0c;团队成员分散&#xff0c;沟通主要靠即时通讯工具&#xff…...

3步解锁SWF逆向工程:JPEXS开源工具深度解析

3步解锁SWF逆向工程&#xff1a;JPEXS开源工具深度解析 【免费下载链接】jpexs-decompiler JPEXS Free Flash Decompiler 项目地址: https://gitcode.com/gh_mirrors/jp/jpexs-decompiler 你是否曾面对一个陈旧的SWF文件束手无策&#xff1f;当Flash技术逐渐退出历史舞台…...

Next.js企业级开发样板Next-Enterprise:一站式集成最佳实践与工具链

1. 项目概述&#xff1a;为什么说 Next-Enterprise 是 Next.js 企业级开发的“瑞士军刀”&#xff1f; 如果你正在用 Next.js 构建一个中大型、对代码质量和开发体验有要求的企业级应用&#xff0c;那你大概率遇到过这些头疼事&#xff1a;项目初始化配置繁琐&#xff0c;得花…...

Arduino程序背后的秘密:从setup/loop到main函数,带你读懂官方核心库源码

Arduino程序背后的秘密&#xff1a;从setup/loop到main函数&#xff0c;带你读懂官方核心库源码 当你第一次打开Arduino IDE&#xff0c;写下setup()和loop()函数时&#xff0c;有没有想过这些代码最终是如何在硬件上运行的&#xff1f;为什么我们不需要写main函数&#xff1f;…...

利用Taotoken模型广场为内容生成应用挑选合适模型

&#x1f680; 告别海外账号与网络限制&#xff01;稳定直连全球优质大模型&#xff0c;限时半价接入中。 &#x1f449; 点击领取海量免费额度 利用Taotoken模型广场为内容生成应用挑选合适模型 对于开发内容生成类应用的团队而言&#xff0c;选择合适的模型是项目成功的关键…...

连接器选型五大雷区:从故障数据到设计落地的实战手册

许多硬件团队的失效分析报告显示&#xff0c;连接器引发的现场故障占比长期居高不下&#xff0c;且症状极其隐蔽——间歇性黑屏、信号丢包、热插拔烧毁……这些问题往往在原型测试阶段难以复现&#xff0c;直到批量出货后才集中爆发。本文从电源、高速信号、射频三类典型应用出…...