课程章节 返回课程首页
-
Ch01 Flink架构与集群搭建
-
Ch02 Flink开发准备
-
Ch03 开发Flink实时处理程序
- Flink流处理程序编程模型
- 创建和使用Flink自定义流数据源
- Flink常用算子
- Flink数据分区和自定义分区器
- Flink数据接收器
- Flink中的时间和水印
- 理解Flink中的窗口概念
- 理解和应用Flink窗口
- Flink窗口函数ReduceFunction
- Flink窗口函数AggreageFunction
- Flink窗口函数ProcessWindowFunction
- Flink中处理迟到的流数据
- Flink流连接
- Flink低级操作函数ProcessFunction
- Flink流程序的状态运算
- Flink状态运算示例_流数据去重
- Flink状态运算示例_窗口计数
- Flink状态运算示例_服务器监控告警程序 VIP
- Flink侧输出流应用
- Flink集成Kafka_读写Kafka
- Flink分层API介绍
- Flink批处理程序开发
- 使用Flink表API进行批处理和流处理
-
Ch04 Flink流处理案例
-
ch05 状态和容错