专注大数据培训
我们一直在领跑

适合人群

在职大数据开发程序猿,具备flink基础知识

有大数据框架开发基础技能,想深入提升的有志青年

学习方式

周末学习

线上方式:跟随线下班进度,每周末收看实时课堂直播

线下方式:每周末,到多易教学楼参加线下面授

学习时长

线下学习周期:4个周末

>>>  获取优惠及报班直达  <<<

课程大纲

章节内容提要
第一章:搞定Flink通信 1.1 Akka的Java编程API深入
1.2 JobManager启动流程和RPC源码分析
1.3 TaskManager启动流程和RPC源码分析
1.4 使用Akka的Java编程API编写Flink简易RPC通信框架
第二章:搞定Flink执行计划 2.1 StreamGraph生成过程源码分析
2.2 JobGraph生成过程源码分析
2.3 ExecutionGraph生成过程源码分析
2.4 物理执行计划生成过程源码分析
第三章:搞定Flink的Task 3.1 Task序列化过程源码分析
3.2 Task调度源码分析
3.3 StreamSource源码分析
3.4 StreamTask源码分析
3.5 StreamSink源码分析
第四章:搞定Flink的CheckPoint和State 4.1 CheckPoint整理流程分析
4.2 重启策略源码分析
4.3 故障恢复策略源码分析
4.4 ValueState源码分析
4.5 OperState源码分析
4.6 CheckPointCoordinator源码分析
4.7 CheckpointedFunction源码分析
4.8 CheckPointListener源码分析
4.9 Barrier源码分析
第五章:搞定Flink窗口 5.1 Window Assinger源码分析
5.2 Window Function源码分析
5.3 WaterMark源码分析
5.4 ProcessingTimeTimer源码分析
5.5 EventTimeTimer源码分析
5.6 Trigger源码分析
5.7 Evictor源码分析
第六章:搞定Flink数据交换(Shuffle) 6.1 RecordWriter源码分析
6.2 ChannelSelector源码分析
6.3 ResultPartition源码分析
6.4 BufferWriter源码分析
6.5 InputGate源码分析
6.6 InputChannel源码分析
6.7 RecordReader源码分析