课程亮点：1，知识体系完备，从小白到大神各阶段读者均能学有所获。2，生动形象，化繁为简，讲解通俗易懂。3，结合工作实践及分析应用，培养解决实际问题的能力。4，每一块知识点, 都有配套案例, 学习不再迷茫。 课程内容：1、Flink框架简介2、Flink集群搭建运维3、Flink Dataset开发4、Flink 广播变量，分布式缓存，累加器5、Flink Datastream开发6、Flink Window操作7、Flink watermark与侧道输出8、Flink状态计算9、Flink容错checkpoint与一致性语义 10、Flink进阶 异步IO，背压，内存管理11、Flink Table API与SQL 适用人群：1、对实时计算领域或者Flink感兴趣的在校生及应届毕业生。2、对目前职业有进一步提升要求，希望从事大数据行业高薪工作的在职人员。3、对大数据行业感兴趣的相关人员。 课程目录介绍第一章 Flink简介01.Flink的引入02.什么是Flink03.Flink流处理特性04.Flink基石05.批处理与流处理 第二章 Flink架构体系01.Flink中重要角色02.无界数据流与有界数据流03.Flink数据流编程模型 04.Libraries支持 第三章 Flink集群搭建 01.环境准备工作02.local模式03.Standalone集群模式04.Standalone-HA集群模式05.Flink On Yarn模式-介绍06.Flink On Yarn模式-准备工作07.Flink On Yarn模式-提交方式-Session会话模式08.Flink On Yarn模式-提交方式-Job分离模式 09. Flink运行架构-Flink程序结构 10. Flink运行架构-Flink并行数据流 11. Flink运行架构-Task和Operator chain 12. Flink运行架构-任务调度与执行 13. Flink运行架构-任务槽与槽共享 第四章 Dataset开发01.入门案例02.入门案例-构建工程、log4j.properties03.入门案例-代码运行yarn模式运行04.DataSource-基于集合05.DataSource-基于文件06.Transformation开发07.Datasink-基于集合08.Datasink-基于文件09.执行模式-本地执行10.执行模式-集群执行11.广播变量12.累加器13.分布式缓存14.扩展并行度的设置 第五章 DataStream开发 01.入门案例-流处理流程02.入门案例-示例、参考代码03.流处理常见Datasource04.Datasource基于集合05.Datasource基于文件06.Datasource基于网络套接字07.Datasource-自定义source-SourceFunction08.Datasource-自定义source-ParallelSourceFunction09.Datasource-自定义source-RichParallelSourceFunction10.Datasource-自定义source-MysqlSource11.Datasource-自定义source-KafkaSource12.DataStream-transformations13.DataSink-输出数据到本地文件14.DataSink-输出数据到本地集合15.DataSink-输出数据到HDFS16.DataSink-输出数据到mysql,kafka,Redis 第六章 Flink中Window01.为什么需要window02.什么是window03.Flink支持的窗口划分方式04.Time-window之tumbling-time-window05.Time-window之sliding-time-window06.Time-window之session-window07.Count-window之tumbling-count-window08.Count-window之sliding-count-window09.window-Apply函数 第七章 Eventime-watermark01.时间分类02.watermark之数据延迟产生03.watermark之解决数据延迟到达04.watermark综合案例05.watermark之数据丢失06.watermark+侧道输出保证数据不丢失 第八章 Flink状态管理01.状态管理概述之无状态计算02.状态管理概述之有状态计算03.状态管理概述之有状态计算场景04.状态的类型之Managed State&Raw State05.状态的类型之Keyed State&Operator State06.API演示之ValueState07.API演示之MapState08.案例之OperatorState09.案例之BroadcastState 第九章 Flink容错&重启策略01.checkpoint是什么02.checkpoint执行流程03.checkpoint持久化存储04.案例之checkpoint设置演示05.Flink重启策略之重启策略配置06.案例之重启策略演示07.Savepoint与checkpoint区别08.案例之savepoint演示09.端到端一致性语义解释10.案例之kafka实现EndToEnd一致性语义11.案例之Mysql实现EndToEnd一致性语义 第十章 Flink扩展_异步IO_反压_内存管理01.异步IO之使用前提02.异步IO之核心API Async IO 03.案例之异步IO案例04.什么是反压问题05.Flink如何解决反压问题06.Flink内存管理07.定制化内存管理08.定制化序列化框架09.使用堆外内存 第十一章 Flink-sql开发01.Flink sql背景02.sql常用算子之select03.sql常用算子之where04.sql常用算子之distinct05.sql常用算子之group by06.sql常用算子之union_union all07.sql常用算子之join08.sql常用算子之group window09.案例之批处理sql案例10.案例之流处理sql案例