VIP20
本课程属于：017-Flink实时计算 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

从零掌握Flink窗口计算核心

📚 共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
第01章
Flink简介与核心概念
Flink是什么、发展历史、应用场景，以及与Spark Streaming的对比分析。
基础概念
第02章
Flink环境搭建与运行
本地模式安装、Standalone集群搭建、YARN部署，并运行首个WordCount程序。
环境入门
第03章
Flink DataStream API基础
DataStream API概述，Source算子（集合、文件、Kafka），Transformation算子（map、flatMap、filter、keyBy）。
API算子
第04章
Flink窗口概念初探
为什么需要窗口，窗口分类（时间窗口、计数窗口），以及窗口的生命周期管理。
窗口核心
第05章
Flink时间语义
Event Time、Processing Time、Ingestion Time的区别，以及如何设置时间特性。
时间语义
第06章
Flink Watermark机制
Watermark概念、必要性，生成策略（周期性、punctuated），传播与计算原理。
Watermark乱序
第07章
Flink窗口分配器
Tumbling、Sliding、Session、Global四种窗口分配器的原理与使用场景。
分配器窗口
第08章
Flink窗口函数（上）
ReduceFunction、AggregateFunction的使用方式与内部实现原理。
增量聚合函数
第09章
Flink窗口函数（下）
ProcessWindowFunction详解，增量聚合与全量聚合的对比及选型建议。
全量聚合Process
第10章
Flink窗口触发器（Trigger）
Trigger作用，内置CountTrigger、ProcessingTimeTrigger、EventTimeTrigger，以及自定义Trigger。
触发器高级
第11章
Flink窗口驱逐器（Evictor）
Evictor作用，内置CountEvictor、TimeEvictor，以及自定义驱逐策略。
驱逐器内存
第12章
Flink窗口允许延迟（Allowed Lateness）
迟到数据处理方式，Side Output侧输出流的使用与最佳实践。
迟到数据侧输出
第13章
Flink窗口状态与容错
窗口状态存储、Checkpointing机制、Savepoint的使用与恢复策略。
状态容错
第14章
Flink多流合并与窗口
Connect、CoGroup、Union在窗口计算中的联合应用与数据关联。
多流合并
第15章
Flink窗口性能优化
窗口数据倾斜处理、内存优化技巧、异步I/O在窗口中的集成使用。
性能优化
第16章
Flink Table & SQL窗口（上）
Table API简介，Group Window（分组窗口）的定义与使用示例。
Table API分组窗口
第17章
Flink Table & SQL窗口（下）
Over Window（Over窗口）的使用，SQL中窗口函数的写法与实战。
SQLOver窗口
第18章
Flink CEP与窗口结合
什么是CEP，Pattern API使用，在窗口内进行复杂事件检测。
CEP模式匹配
第19章
Flink窗口实战案例（一）
实时PV/UV统计：滚动窗口 + Redis去重，精确流量分析。
实战PV/UV
第20章
Flink窗口实战案例（二）
实时订单金额统计：滑动窗口 + Exactly-Once语义保证。
实战订单
第21章
Flink窗口实战案例（三）
用户行为路径分析：Session窗口 + CEP 识别完整旅程。
实战行为路径
第22章
Flink窗口实战案例（四）
实时热门商品TopN：滑动窗口 + ProcessWindowFunction 动态排名。
实战TopN
第23章
Flink窗口实战案例（五）
实时异常检测：自定义Trigger + 侧输出流，精准告警。
实战异常检测
第24章
Flink窗口监控与调优
Flink Web UI监控窗口指标、反压检测、窗口延迟优化策略。
监控调优
第25章
Flink 1.14+ 窗口新特性
Window TVF（表值函数）、窗口聚合优化、SQL窗口性能提升。
新特性TVF
第26章
Flink窗口与状态后端
RocksDB状态后端优化、增量Checkpoint、大状态下的窗口处理。
状态后端RocksDB
第27章
Flink窗口与事件时间对齐
跨时区窗口处理、夏令时问题、自定义时间提取器。
时区事件时间
第28章
Flink窗口在实时数仓中的应用
DWD层窗口ETL、DWS层窗口聚合、ADS层窗口输出。
实时数仓分层
第29章
Flink窗口常见问题与避坑指南
数据乱序严重、窗口结果不准确排查、内存溢出处理等实战经验。
避坑排查
第30章
Flink窗口未来展望与总结
Flink窗口发展趋势、学习路径建议、项目实战总结与进阶方向。
总结展望
专注课程资料整理