课程费用

5800.00 /人

课程时长

2

成为教练

课程简介

本课程主要讲解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实现企业级数据流转功能

项目实战
项目重难点分析
项目优化
提交需求