课程简介
本课程主要讲解Flink的核心设计原理,实时计算,SQL计算,离线计算功能和使用场景,同时通过实战案例与实际业务的场景相结合,让学员轻松掌握Flink在实时计算领域的独特魅力。
本次课程的代码实现以 Scala语言为主,配套有Java语言代码实现,要求学员至少具备Java基础,讲师会提供培训过程中用到的项目代码(Scala实现和Java实现)。
目标收益
通过实战案例与实际业务的场景相结合,让学员轻松掌握Flink在实时计算领域的独特魅力。
培训对象
大数据开发工程师,对实时计算感兴趣的人员
课程大纲
第一天上午:Flink快速理解&案例实战 |
Flink基本原理 Flink核心设计原理 Flink整体架构分析 Flink API层面架构分析 Flink使用场景分析 Flink集群部署方式分析 Flink实时计算案例实战 Flink离线计算案例实战 |
第一天下午:Flink常用功能分析 |
Flink Datastrema 常用算子分析 Flink Dataset常用算子分析 Flink中的高级功能之Broadcast Flink中的高级功能之Accumulators 和Counters Flink中的高级功能之Distributed Cache Flink中的state管理与恢复机制分析 |
第二天上午:Flink高级功能分析&案例实战 |
Flink中的window详解 Flink中的Time详细分析 Flink中的Parallel分析 Flink中的CEP功能分析 Flink中的数据乱序问题分析 Flink中的watermark机制介绍 Flink中watermark案例实战【解决实时计算数据乱序问题】 |
第二天下午:Flink高级功能分析&项目实战 |
Flink中的SQL计算功能分析 Flink SQL计算平台架构分析 Flink SQL实现企业级数据流转功能 项目实战 项目重难点分析 项目优化 |
第一天上午:Flink快速理解&案例实战 Flink基本原理 Flink核心设计原理 Flink整体架构分析 Flink API层面架构分析 Flink使用场景分析 Flink集群部署方式分析 Flink实时计算案例实战 Flink离线计算案例实战 |
第一天下午:Flink常用功能分析 Flink Datastrema 常用算子分析 Flink Dataset常用算子分析 Flink中的高级功能之Broadcast Flink中的高级功能之Accumulators 和Counters Flink中的高级功能之Distributed Cache Flink中的state管理与恢复机制分析 |
第二天上午:Flink高级功能分析&案例实战 Flink中的window详解 Flink中的Time详细分析 Flink中的Parallel分析 Flink中的CEP功能分析 Flink中的数据乱序问题分析 Flink中的watermark机制介绍 Flink中watermark案例实战【解决实时计算数据乱序问题】 |
第二天下午:Flink高级功能分析&项目实战 Flink中的SQL计算功能分析 Flink SQL计算平台架构分析 Flink SQL实现企业级数据流转功能 项目实战 项目重难点分析 项目优化 |