一. 概述 本项目为flink练手项目,主要为熟悉flink的基本操作&使用. 二. 清单 2.1. Flink使用DataStream API 读取数据 代码位置: src/main/scala/com/boyi/datasource 2.2. 算子操作 代码位置: src/main/scala/com/boyi/transform 2.3.广播变量/累加器/分布式缓存 代码位置: src/main/scala/com/boyi/other 2.4. sink 操作 代码位置: src/main/scala/com/boyi/sink 2.5. xxxx 2.6. xxxx 2.7. xxxx