【天天新要闻】大数据Flink进阶(五):Flink开发环境准备
Flink开发环境准备
学习一门新的编程语言时,往往会从"hello world"程序开始,而接触一套新的大数据计算框架时,则一般会从WordCount案例入手,下面以大数据中最经典入门案例WordCount为例,来编写Flink代码,Flink底层源码是基于Java代码进行开发,在Flink编程中我们除了可以使用Java语言来进行编写Flink程序外,还可以使用Scala、Python语言来进行编写Flink程序,在后文章中我们将会主要使用Java和Scala来编写Flink程序。下面来准备下Flink开发环境。
一、Flink版本
本套课程中我们采用Flink最新版本1.16.0,Flink1.16.0版本官方文档地址:
(相关资料图)
https://nightlies.apache.org/flink/flink-docs-release-1.16/
二、JDK环境
Flink核心模块均采用Java开发,所以运行环境需要依赖JDK,Flink可以基于类UNIX 环境中运行,例如:Linux、Max OS、Windows等,在这些系统上运行Flink时都需要配置JDK环境,Flink 1.16.0版本需要JDK版本为JDK11,目前版本也支持使用JDK8,后续版本对JDK8的支持将会移除。
考虑到Flink后期与一些大数据框架进行整合,这些大数据框架对JDK11的支持并不完善,例如:Hive3.1.3版本还不支持JDK11,所以本课程采用JDK8来开发Flink。对JDK8安装及配置不再详述。
附:JDK11 下载地址如下:
https://www.oracle.com/java/technologies/javase-jdk11-downloads.html
三、开发工具
我们可以选择IntelliJ IDEA或者Eclipse作为Flink应用的开发IDE,Flink开发官方建议使用IntelliJ IDEA,因为它默认集成了Scala和Maven环境,使用更加方便,我们这门课使用IntelliJ IDEA开发工具,具体安装步骤不再详述。
四、Maven环境
通过IntelliJ IDEA进行开发Flink Application时,可以使用Maven来作为项目jar包管理工具,需要在本地安装Maven及配置Maven的环境变量,需要注意的是,Maven版本需要使用3.0.4及以上,否则编译或开发过程中会有问题。这里使用Maven 3.2.5版本。
五、Scala环境
Flink开发语言可以选择Java、Scala、Python,如果用户选择使用Scala作为Flink应用开发语言,则需要安装Scala执行环境。
在Flink1.15之前版本,如果只是使用Flink的Java api ,对于一些没有Scala模块的包和表相关模块的包需要在Maven引入对应的包中加入scala后缀,例如:flink-table-planner_2.11,后缀2.11代表的就是Scala版本。在Flink1.15.0版本后,Flink添加对opting-out(排除) Scala的支持,如果你只使用Flink的Java api,导入包也不必包含scala后缀,你可以使用任何Scala版本。如果使用Flink的Scala api,需要选择匹配的Scala版本。
从Flink1.7版本往后支持Scala 2.11和2.12版本,从Flink1.15.0版本后只支持Scala 2.12,不再支持Scala 2.11。Scala环境可以通过本地安装Scala执行环境,也可以通过Maven依赖Scala-lib引入,如果本地安装了Scala某个版本,建议在Maven中添加Scala-lib依赖。Scala2.12.8之后的版本与之前的2.12.x版本不兼容,建议使用Scala2.12.8之后版本。
六、Hadoop环境
Flink可以操作HDFS中的数据及基于Yarn进行资源调度,所以需要对应的Hadoop环境,Flink1.16.0版本支持的Hadoop最低版本为2.8.5,本课程中我们使用Hadoop3.3.4版本。关于Hadoop3.3.4版本搭建,后续文章会手把手进行搭建。
标签:
精彩推送
2023北京高考体检会诊时间是什么时候? 全球今热点
2023年北京高考体检会诊时间是什么时候?体检会诊时间:2023年3月10日至4月10日期间,每周三下午13:30-1...
新资讯:筹划裁员30%?新华基金称当前个别部门人员离职是正常优化和末位淘汰
筹划裁员30%?新华基金称当前个别部门人员离职是正常优化和末位淘汰,裁员,离职,新华基金,末位淘汰,迈克...
新闻快讯
X 关闭
X 关闭
新闻快讯
- 【天天新要闻】大数据Flink进阶(五):Flink开发环境准备
- 天天新动态:迪士尼被曝将继续裁员4000人,2月宣布公司战略重组
- 院景有“钱景” 多彩庭院盘活乡村“微经济”|每日热文
- 世界实时:感时花溅泪 恨别鸟惊心 使用了什么修辞手法
- 麦当劳更名了吗_麦当劳更名_全球报道
- 家装装修施工合同范本_家装施工合同范本
- 诈骗罪十万判多少年|通讯
- 去眼袋最有效的眼霜适合45岁_去眼袋最有效的眼霜
- 恍然大悟中悟的意思是(恍然大悟中悟的意思)-世界快消息
- 血清促甲状腺激素 焦点资讯
- 五彩缤纷洒红节
- 丝路视觉(300556)81万股限售股将于3月20日解禁上市,占总股本0.68%|当前播报
- 全球热消息:报告:2022年国人每晚平均睡眠7.40小时,整体睡眠状况有所改善
- 章泽天_说一说章泽天的简介
- 刑事诉讼的律师费收费标准是多少_焦点日报
- 环球快资讯:真人版《小美人鱼》上映前再爆话题热度,网友唱衰喝倒彩
- CATL在2020年第三季度增加了销售额和净利润 天天观天下
- 奔组词多音字的近义词
- 林业标准化管理办法_关于林业标准化管理办法简述-全球信息
- 到底是什么造化,吸引我们一生至少要去一趟五台?
- 不必再等?微软疑似全面开放新必应_当前焦点
- 前沿资讯!成都2023年美团校园招聘
- 湖南师大教务系统_南师大教务系统|天天消息
- 景嘉微3月17日快速上涨
- 劲舞团自由舞步_劲舞团机械舞步-每日快报
- 京能电力(600578):3月16日北向资金增持26.09万股 世界新动态
- 吃樱桃的好处_吃樱桃的好处有哪些
- 小米手机如何省电_省电的妙招
- 电三轮侧翻,郓城一老人受伤倒地……
- 要闻:万得凯(301309)3月16日主力资金净买入782.23万元
- 3月16日,金蝶国际(00268.HK)举行2022年全年业绩发布会 今日热议
- 万国数据-SW(09698.HK)年度净亏损12.66亿人民币
- 每日焦点!博睿数据:3月15日融资买入475.36万元,融资融券余额4139.27万元
- 农一师各团干部公示(农一师)
- 南京证券(601990):3月15日北向资金减持220.5万股|天天微动态
- 今日学习网络折叠 当前动态
- 公司评测| 龙讯旷腾完成近亿元A轮融资 其材料计算软件PWmat已入驻腾讯TEFS-世界实时
- 南宁老人公租房怎么申请
- 2023郑州网约车资格证报名费多少钱
- 实况足球2012角球让防守人员撞墙-实况足球2012角球
- 全县“庸懒散拖”问题专项教育整治干部讲评会召开|当前热讯
- 世界简讯:国产榴莲要来啦!网友有个期待→
- 科汇股份:融资净买入56.5万元,融资余额6391.72万元(03-14)
- 【天天报资讯】笔记本超级本游戏本有什么区别_笔记本 超级本 游戏本有什么区别
- 全球今热点:e52450处理器怎么样可以玩吃鸡_e52450处理器怎么样
- 秋分日_秋分时间
- 天天看点:中冶置业拟发行20亿元公司债券
- 再敲安全警钟!九江交管部门约谈8家共享电动车企业 独家焦点
- pdf文件怎么修改_如何修改pdf文件
- 德石股份:公司在中东的沙特、伊拉克、阿联酋都有客户采购公司的产品-世界热讯