4. DataStream API# 4.1. Flink 程序的骨架结构 设置执行环境 读取数据源 进行转换操作 结果输出 执行 4.2. Transformations 单数据流转换 map filter flatMap 基于 Key 的分组转换 keyBy Aggregation reduce 多数据流转换 union connect 并行度与数据重分布 并行度 数据重分布 shuffle rebalance 与 rescale broadcast global partitionCustom 4.3. 数据类型和序列化 Flink 支持的数据类型 基础类型 数组 复合类型 Scala case class Java POJO Tuple 辅助类型 泛型和其他类型 TypeInformation 注册类 注册序列化器 4.4. 用户自定义函数 函数类 Lambda 表达式 Scala 的 Lambda 表达式 Java Rich 函数类 4.5. 案例实战：股票数据流处理 实验目的 实验内容 实验要求 实验报告
