1. Window介绍 a. 为什么要有Window b. Window类型 2. Window API的使用 a. Window的三大组件 b. Time&watermark c. 时间语义 d. 乱序问题解决WaterMark e. AllowLateness正确设置与理解 f. Sideoutput在Window中的使用 3. Window的内部实现原理 a. Window的处理流程 b. Window中的状态存储 4. 生产环境中的Window使用遇到的一些问题
第四课: Connector
1. 基本Connnector 2. 自定义Source 与 Sink a. Kafka简介 b. Kafka Consumer 与Sink 的正确使用方式 c. Kafka-Connector 内部机制与实现原理
第五课: 状态管理与恢复机制
1. 基本概念 2. KeyState 基本类型及用法 a. ValueState b. ListState c. ReduceState d. FoldState e. AggregatingState 3. OperatorState基本用法 4. Checkpoint a. 概念 b. 开启checkpoint c. 基本原理
第六课: Metrics 与监控
1. Metrics的种类 2. Metrics的获取方式 a. Web Ui b. Rest API c. MetricReporter 3. 用户自定义Metric指标方式 4. 监控和诊断:Metric和Druid 实时OLAP联合使用 a. Metric上报 b. Metric指标聚合 c. Metric的分类和格式定义 5. Druid查询和指标系统 a. Flink作业反压监控 b. Flink作业的延迟监控 c. 其他 6. Metric系统的内部实现 7. 生产环境中的案例分析 -- 通过指标来排查应用问题
第七课: Flink应用案例介绍
1. 数据清洗:map/flatmap等 2. 监控告警系统 a. 数据拉平 b. 基础窗口计算等 3. 线上运营系统 4. 风控系统