课程章节 返回课程首页
-
Ch01 Flink架构与集群搭建
-
Ch02 Flink开发准备
-
Ch03 开发Flink实时处理程序
- Flink流处理程序编程模型
- Flink流应用程序剖析
- 读取Socket数据源
- 读取文件数据源
- 使用集合数据源
- 自定义数据源
- 数据转换-map
- 数据转换-flatMap
- 数据转换-filter
- 数据转换-keyBy
- 数据转换-reduce
- 数据转换-聚合转换
- 数据转换-union
- 数据转换-connect
- 数据转换-project
- Flink数据分区
- 自定义数据分区示例
- 将流计算结果写出到CSV文件
- 将流计算结果保存到MySQL数据库中
- 时间和水印
- 水印策略
- Flink窗口操作概念及示例
- Flink低级操作API_ProcessFunction
- 案例：服务器故障检测报警程序 VIP
- 侧输出流
- 使用Kafka连接器
- 使用JDBC连接器
-
Ch04 Flink流处理案例
-
ch05 状态和容错