TA的每日心情 | 开心 2024-9-19 21:14 |
---|
签到天数: 757 天 [LV.10]以坛为家III
管理员
- 积分
- 1312677
|
资源详情
课程目标
《Flink进阶及实战》课程主要讲述了Flink实时框架的基本操作使用以及案例实战开发。
适用人群
对大数据、实时计算感兴趣的同学,需要具备一定的编程基础(jA危ascala)。
课程简介
本套课程基于Flink**版本V1.6.1
本套课程主要针对Flink进阶及实战下半部分内容进行讲解,侧重于实战演练。
Flink进阶及实战(下)-课程安排
1:课程内容介绍
2:DataStreamAPI之source讲解-(jA危a代码)
3:DataStreamAPI之自定义source-1-(jA危a代码)
4:DataStreamAPI之自定义source-2-(jA危a代码)
5:DataStreamAPI之transformation-(jA危a代码)
6:DataStreamAPI之partition-(jA危a代码)
7:DataStreamAPI之sink-(jA危a代码)
8:DataStreamAPI之source-(scala代码)
9:DataStreamAPI之transformation-(scala代码)
10:DataStreamAPI之partition-(scala代码)
11:DataStreamAPI之sink-(scala代码)
12:DataSetAPI之transformation-1-(jA危a代码)
13:DataSetAPI之transformation-2-(jA危a代码)
14:DataSetAPI之partition-(jA危a代码)
15:DataSetAPI之transformation-1-(scala代码)
16:DataSetAPI之transformation-2-(scala代码)
17:TableApi简介+Flink支持的dataType和序列化
18:FlinkBroadcast广播变量-(jA危a代码)
19:FlinkBroadcast广播变量-(scala代码)
20:FlinkAccumulators-Counters-(jA危a代码)
21:FlinkAccumulators-Counters-(scala代码)
22:FlinkDistributedCache-(jA危a+scala代码)
23:Flinkstate之keyedState分析
24:Flinkstate之operatorState分析
25:FlinkcheckPoint分析
26:Flinkstatebackend详细分析
27:Flinkstatebackend实战演示
28:FlinkRestartStrategies(重启策略)分析
29:Flink从checkpoint恢复数据
30:FlinksA危ePoint的使用详解
31:Flinkwindow详解
32:Flinktime介绍
33:Flinkwatermark介绍
34:Flinkwatermark解决乱序数据-1
35:Flinkwatermark解决乱序数据-2
36:Flinkparallelism并行度分析
37:FlinkUI界面介绍
38:Flinkkafka-connector分析
39:Flinkkafka-connector代码操作-(jA危a代码)
40:Flinkkafka-connector代码操作-(scala代码)
41:Flink生产环境配置介绍
42:实战需求分析(数据清洗[实时ETL])
43:数据清洗[实时ETL]-jA危a代码实现-1
44:数据清洗[实时ETL]-jA危a代码实现-2
45:数据清洗[实时ETL]-jA危a代码提交集群运行
46:数据清洗[实时ETL]-把任务提交命令封装成脚本
47:数据清洗[实时ETL]-scala代码实现
48:实战需求分析(数据报表)
49:数据报表-jA危a代码实现-1
50:数据报表-jA危a代码实现-2
51:数据报表-es和kibana的安装
52:数据报表-运行任务
53:数据报表-执行脚本封装
54:数据报表-scala代码实现
55:项目代码地址
本次授课,考虑到大多数学员是jA危a程序员,
会基于jA危a代码+scala代码讲解
|
|