2第二章 Apache Flink 快速入门
2.1Flink开发环境准备
学习一门新的编程语言时,往往会从"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。
开发工具