Apache Flink作为当前大数据领域最炙手可热的流处理框架,已经成为实时计算方向技术人必须掌握的核心技能之一。这套《Flink核心技术实战:从入门到精通》课程,正是为希望系统学习Flink并落地实战的开发者量身打造,内容覆盖从基础概念到高级特性的完整知识链路。

课程内容全面,层层递进
课程从流处理技术概览与Flink发展历史讲起,帮助学员建立对实时计算领域的整体认知。随后深入Flink集群架构、运行模式与资源管理器支持,涵盖Standalone、On Yarn、On Kubernetes等多种部署方式的原理讲解与实操演示,并专门讲解高可用配置的落地方法。
核心API与实战并重
在分布式流处理模型的基础上,课程系统讲解DataStream API的实践原理,包括时间概念、Watermark机制、窗口计算(Window Assigner、Trigger、Evictors、Window Function、多流合并)、Process Function、SideOutput旁路输出、Asynchronous IO异步操作等关键知识点。同时深入剖析Flink类型系统、Pipeline与StreamGraph转换、自定义SourceFunction等进阶内容,并配有基于DataStream API实现PV、UV统计的项目实战。
状态管理与容错机制深入解析
课程对有状态计算、KeyedState、OperatorState、BroadcastState等状态类型进行详细介绍,深入讲解Checkpoint实现原理、Savepoint与Checkpoint的区别、StateBackends状态管理器、State Schema Evolution、状态序列化与反序列化、Querable State等高级主题。配合实时交易反欺诈项目实战,帮助学员真正理解Flink在金融级场景下的容错与状态管理能力。
Table API与SQL生态完整覆盖
从Table API与SQL的介绍与使用入手,课程讲解核心概念、DataStream/DataSet与Table相互转换、Table Connector、Querying Dynamic Tables、时间属性定义、Temporal Condition、动态表Join、Temporal Function、Catalog原理与使用、Apache Hive集成、SQL Client、Flink SQL Table数据类型、自定义Function与Connector、new table source & table sink API等内容,并以基于Flink SQL实现Top10商品统计的项目实战收尾。
Runtime架构与调优实战
课程深入Runtime整体架构,涵盖Flink Client实现原理、ResourceManager资源管理、Dispatcher任务分发器、JobGraph提交与运行、Task执行与调度、Task重启和容错策略、集群组件Rpc通信机制、NetworkStack实现原理、Flink内存管理、Metric指标分类与采集、RestAPI、Checkpoint监控与调优、反压监控与原理、内存配置与调优等运维调优必备知识。
拓展生态与综合项目
课程还涉及PyFlink实践与应用、复杂事件处理(CEP)、Alink机器学习框架、Stateful Function等生态扩展内容,并以实时推荐系统项目设计与实现作为综合实战,帮助学员将所学知识融会贯通。
整套课程共91节视频加配套资料,内容由浅入深、理论与实操结合紧密,适合大数据工程师、数据科学家以及所有对实时计算感兴趣的技术人员系统学习与提升。

10积分
