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依赖