博学谷 > 优质课 > Flink入门到实战

Flink入门到实战

Flink入门到实战

随着Flink技术的飞速发展,Flink在实时处理数据方面体现出越来越显著的优势。Flink作为一个针对流数据和批数据的分布式处理引擎,其应用领域越来越广泛。本课程将从Flink一站式处理框架的基础安装/技术要点/相关操作等进行讲解,并结合Flink电商项目,让学习者快速掌握Flink相关的开发技术。

主讲:大数据高级讲师 | 课程时长:30课时 | 学习人数:116人 | 难度: 基础

¥199.00

立即报名

第 一 章:就业课(2.1)-Flink基础

1-1 Flink基础介绍

1-1-1 01_学习目标
1-1-2 02_Flink介绍_Flink引入
1-1-3 03_Flink介绍_什么是Flink
1-1-4 04_Flink介绍_性能比较
1-1-5 05_Flink和阿里巴巴
1-1-6 06_Flink部署_伪集群模式安装
1-1-7 07_Flink部署_StandAlone集群模式安装
1-1-8 08_Flink部署_StandAlone集群HA模式安装
1-1-9 09_Flink部署_Yarn集群环境
1-1-10 10_Flink部署_Yarn-session介绍_会话模式
1-1-11 11_Flink部署_分离模式
1-1-12 12_Flink基石介绍
1-1-13 13_Flink组件栈
1-1-14 14_Flink编程模型
1-1-15 15_Flink程序结构
1-1-16 16_Flink并行数据流
1-1-17 17_任务调度与执行
1-1-18 18_Flink统一的流处理与批处理
1-1-19 19_Flink的应用场景

1-2 Flink批处理开发

1-2-1 01_学习目标
1-2-2 02_批处理环境搭建
1-2-3 03_加载本地数据源
1-2-4 04_加载文件数据源
1-2-5 05_Transformation简介
1-2-6 06_转换操作_map
1-2-7 07_转换操作_flatmap
1-2-8 08_转换操作_mapPartition
1-2-9 09_转换操作_filter
1-2-10 10_转换操作_reduce
1-2-11 11_转换操作_reduceGruop
1-2-12 12_转换操作_aggregate
1-2-13 13_转换操作_distinct
1-2-14 14_转换操作_union
1-2-15 15_转换操作_rebalance
1-2-16 16_转换操作_PartitionByHash
1-2-17 17_转换操作_sortPartition
1-2-18 18_落地操作_本地集合
1-2-19 19_落地操作_本地文件
1-2-20 20_Flink本地执行环境
1-2-21 21_Flink集群执行环境
1-2-22 22_广播变量
1-2-23 23_Flink的累加器
1-2-24 24_分布式缓存

1-3 Flink流处理开发

1-3-1 01_学习目标
1-3-2 02_数据源_集合
1-3-3 03_数据源_基于文件
1-3-4 04_数据源_基于网络套接字
1-3-5 05_数据源_自定义source
1-3-6 06_数据源_Kafka
1-3-7 07_数据源_MySQL
1-3-8 08_转换操作_keyBy
1-3-9 09_转换操作_Connect
1-3-10 10_转换操作_Split和select
1-3-11 11_数据落地_Kafka
1-3-12 12_数据落地_MySql
1-3-13 13_Window操作_什么是Window
1-3-14 14_Window操作_时间窗口介绍
1-3-15 15_Window操作_TumblingTimeWindow
1-3-16 16_Window操作_SlidingTimeWindow
1-3-17 17_Window操作_CountWindow
1-3-18 18_Window操作_ apply
1-3-19 19_水印机制_时间类型
1-3-20 20_水印机制_介绍
1-3-21 21_水印机制_代码实现

第 二 章:就业课(2.1)-Flink 高级进阶

2-1 Flink高级开发

2-1-1 01_学习目标
2-1-2 02_State介绍
2-1-3 03_Keyed State介绍
2-1-4 04_Operate State介绍
2-1-5 05_CheckPoint介绍
2-1-6 06_Barrier介绍
2-1-7 07_Checkpoint持久化方案
2-1-8 08_CheckPoint案例介绍
2-1-9 09_CheckPoint案例开发-自定义数据源
2-1-10 10_CheckPoint案例开发-自定义状态
2-1-11 11_CheckPoint案例开发-自定义Window和检查点
2-1-12 12_CheckPoint案例开发-主业务
2-1-13 13_FlinkSql_介绍
2-1-14 14_Table API和SQL程序的结构
2-1-15 15_FlinkSql_入门案例_DataStream或DataSet转换为表格
2-1-16 16_FlinkSql_入门案例_表转换为DataStream
2-1-17 17_FlinkSql_入门案例_表转换为DataSet
2-1-18 18_FlinkSql_批处理案例1
2-1-19 19_FlinkSql_批处理案例2
2-1-20 20_FlinkSql_流处理案例

第 三 章:就业课(2.1)-Flink电商指标分析项目

3-1 项目简介以及上报服务系统开发

3-1-1 01_项目简介
3-1-2 02_项目流程介绍
3-1-3 03_项目的技术选型
3-1-4 04_IDEA工程搭建
3-1-5 05_SpringBoot简介
3-1-6 06_SpringBoot入门案例
3-1-7 07_Kafka-Manager安装
3-1-8 08_KafkaTemplate创建
3-1-9 09_KafkaTemplate测试
3-1-10 10_自定义分区
3-1-11 11_上报服务模块编写
3-1-12 12_消息模拟器

3-2 Flink整合kafka开发

3-2-1 13_实时分析系统介绍
3-2-2 14_ConfigFactory使用
3-2-3 15_初始化Flink流式环境
3-2-4 16_添加checkpoint的支持
3-2-5 17_整合Kafka
3-2-6 18_消息转换为元组
3-2-7 19_消息转换为样例类ClickLog
3-2-8 20_消息转换为样例类Message
3-2-9 21_添加水印支持

3-3 HBaseUtil工具类开发

3-3-1 01_HBase工具类介绍
3-3-2 02_HBaseUtil基本设置
3-3-3 03_HBaseUtil之getTable编写
3-3-4 04_HBaseUtil之putData
3-3-5 05_HBaseUtil之getData
3-3-6 06_HBaseUtil之putMapData
3-3-7 07_HBaseUtil之getMapData
3-3-8 08_HBaseUtil之deleteData

3-4 实时数据业务分析开发

3-4-1 09_业务开发流程介绍
3-4-2 10_实时数据预处理_创建宽表样例类
3-4-3 11_实时数据预处理_扩宽地域时间
3-4-4 12_实时数据预处理_扩宽isNew
3-4-5 13_实时数据预处理_扩宽isHourNew_isDayNew_isMonthNew
3-4-6 14_业务分析_实时频道热点
3-4-7 15_业务分析_实时频道热点_落地HBase
3-4-8 16_业务分析_频道小时维度PVUV
3-4-9 17_业务分析_频道天月维度PVUV
3-4-10 18_业务分析_用户新鲜度
3-4-11 19_业务分析_用户新鲜度_落地HBase
3-4-12 1_业务分析_模板方法抽取BaseTask
3-4-13 2_业务分析_重构新鲜度分析
3-4-14 3_业务分析_频道地域
3-4-15 4_业务分析_频道地域落地HBase
3-4-16 5_业务分析_运营商分析
3-4-17 6_业务分析_运营商分析_落地HBase
3-4-18 7_业务分析_浏览器分析

3-5 实时数据同步系统开发

3-5-1 8_实时同步系统介绍
3-5-2 9_采集方案_LogStash介绍
3-5-3 10_采集方案_Canal介绍
3-5-4 11_数据库采集系统介绍
3-5-5 12_MySql离线安装
3-5-6 13_MySql开启binlog
3-5-7 14_MySql主从复制介绍
3-5-8 15_Cananl原理介绍
3-5-9 16_Canal安装
3-5-10 17_Canal采集程序搭建【废弃待重录】
3-5-11 01_binlog说明
3-5-12 02_Flink实时同步应用开发介绍
3-5-13 03_项目初始化
3-5-14 04_Flink初始化
3-5-15 05_Flink整合Kafka
3-5-16 06_消息转换为Canal样例类
3-5-17 07_添加水印
3-5-18 08_HBaseOperation样例类
3-5-19 09_Canal转HBaseOperation介绍
3-5-20 10_PreprocessTask开发
3-5-21 11_Canal数据存储到HBase

3-6 Flink离线分析系统开发

3-6-1 12_离线分析系统简介
3-6-2 13_初始化Flink批处理环境
3-6-3 14_导入测试数据
3-6-4 15_整合HBase
3-6-5 16_测试读取HBase表数据_解决版本冲突
3-6-6 17_JSON转换为样例类
3-6-7 18_数据预处理_拓宽时间字段
3-6-8 19_业务分析_不同支付方式
3-6-9 20_业务分析_不同商家
3-6-10 21_项目总结

猜你还感兴趣

暂无推荐课程,自己逛逛吧

提示
该课程已在购物车中了,无需重复加入
去购物车