大数据开发 | 如何从零搭建Flink项目?

Flink提供了多个层次的API供开发者使用,越往上抽象程度越高,使用起来越方便;越往下越底层,使用起来难度越大

注意:在Flink1.12时支持流批一体,DataSetAPI已经不推荐使用了,所以课程中除了个别案例使用DataSet外,后续其他案例都会优先使用DataStream流式API,既支持无界数据处理/流处理,也支持有界数据处理/批处理!当然Table&SQL-API会单独学习

https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/dataset/overview/

https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/overview/

获取Flink流处理执行环境

构建source

数据处理

构建sink

4.1 创建Maven项目

创建maven项目,项目名称:flinkbase

4.2 导入pom依赖


资源下载: