1. flink程序结构
- 设置执行环境
- 读取输入流
- 应用转换
- 输出结果
- 执行
2. flink转换操作
2.1 基本转换
- Map
- Filter
- FlapMap：FlapMap是Map和Filter的泛化
2.2 基于KeyedStream的转换（keyBy）
- 滚动聚合：sum()、min()、max()、min()、maxBy()
- Reduce：Reduce是滚动聚合函数的泛化
2.3 多流转化
- Union
- Connect、coMap、coFlatMap
- Split、Select
2.4 分发转换
- shuffle： 随机发给下游算子
- rebalance：轮询方式发给下游算子
- rescale：在部分下游算子中轮询
- broadcast：广播
- globle：永远发送个第一个算子
- forward：一对一发送个下游算子（仅在上下游算子并行度一致时才能使用）
- partitionCustom：自定义（这里只能自定义单播）
3. DataStream转换路径
