课程试听
第一章 就业课(2.1)-Flink基础
1-1 Flink基础介绍
- 01_学习目标
- 02_Flink介绍_Flink引入
- 03_Flink介绍_什么是Flink
- 04_Flink介绍_性能比较
- 05_Flink和阿里巴巴
- 06_Flink部署_伪集群模式安装
- 07_Flink部署_StandAlone集群模式安装
- 08_Flink部署_StandAlone集群HA模式安装
- 09_Flink部署_Yarn集群环境
- 10_Flink部署_Yarn-session介绍_会话模式
- 11_Flink部署_分离模式
- 12_Flink基石介绍
- 13_Flink组件栈
- 14_Flink编程模型
- 15_Flink程序结构
- 16_Flink并行数据流
- 17_任务调度与执行
- 18_Flink统一的流处理与批处理
- 19_Flink的应用场景
1-2 Flink批处理开发
- 01_学习目标
- 02_批处理环境搭建
- 03_加载本地数据源
- 04_加载文件数据源
- 05_Transformation简介
- 06_转换操作_map
- 07_转换操作_flatmap
- 08_转换操作_mapPartition
- 09_转换操作_filter
- 10_转换操作_reduce
- 11_转换操作_reduceGruop
- 12_转换操作_aggregate
- 13_转换操作_distinct
- 14_转换操作_union
- 15_转换操作_rebalance
- 16_转换操作_PartitionByHash
- 17_转换操作_sortPartition
- 18_落地操作_本地集合
- 19_落地操作_本地文件
- 20_Flink本地执行环境
- 21_Flink集群执行环境
- 22_广播变量
- 23_Flink的累加器
- 24_分布式缓存
1-3 Flink流处理开发
- 01_学习目标
- 02_数据源_集合
- 03_数据源_基于文件
- 04_数据源_基于网络套接字
- 05_数据源_自定义source
- 06_数据源_Kafka
- 07_数据源_MySQL
- 08_转换操作_keyBy
- 09_转换操作_Connect
- 10_转换操作_Split和select
- 11_数据落地_Kafka
- 12_数据落地_MySql
- 13_Window操作_什么是Window
- 14_Window操作_时间窗口介绍
- 15_Window操作_TumblingTimeWindow
- 16_Window操作_SlidingTimeWindow
- 17_Window操作_CountWindow
- 18_Window操作_ apply
- 19_水印机制_时间类型
- 20_水印机制_介绍
- 21_水印机制_代码实现
第二章 就业课(2.1)-Flink 高级进阶
2-1 Flink高级开发
- 01_学习目标
- 02_State介绍
- 03_Keyed State介绍
- 04_Operate State介绍
- 05_CheckPoint介绍
- 06_Barrier介绍
- 07_Checkpoint持久化方案
- 08_CheckPoint案例介绍
- 09_CheckPoint案例开发-自定义数据源
- 10_CheckPoint案例开发-自定义状态
- 11_CheckPoint案例开发-自定义Window和检查点
- 12_CheckPoint案例开发-主业务
- 13_FlinkSql_介绍
- 14_Table API和SQL程序的结构
- 15_FlinkSql_入门案例_DataStream或DataSet转换为表格
- 16_FlinkSql_入门案例_表转换为DataStream
- 17_FlinkSql_入门案例_表转换为DataSet
- 18_FlinkSql_批处理案例1
- 19_FlinkSql_批处理案例2
- 20_FlinkSql_流处理案例
第三章 就业课(2.1)-Flink电商指标分析项目
3-1 项目简介以及上报服务系统开发
- 01_项目简介
- 02_项目流程介绍
- 03_项目的技术选型
- 04_IDEA工程搭建
- 05_SpringBoot简介
- 06_SpringBoot入门案例
- 07_Kafka-Manager安装
- 08_KafkaTemplate创建
- 09_KafkaTemplate测试
- 10_自定义分区
- 11_上报服务模块编写
- 12_消息模拟器
3-2 Flink整合kafka开发
- 13_实时分析系统介绍
- 14_ConfigFactory使用
- 15_初始化Flink流式环境
- 16_添加checkpoint的支持
- 17_整合Kafka
- 18_消息转换为元组
- 19_消息转换为样例类ClickLog
- 20_消息转换为样例类Message
- 21_添加水印支持
3-3 HBaseUtil工具类开发
- 01_HBase工具类介绍
- 02_HBaseUtil基本设置
- 03_HBaseUtil之getTable编写
- 04_HBaseUtil之putData
- 05_HBaseUtil之getData
- 06_HBaseUtil之putMapData
- 07_HBaseUtil之getMapData
- 08_HBaseUtil之deleteData
3-4 实时数据业务分析开发
- 09_业务开发流程介绍
- 10_实时数据预处理_创建宽表样例类
- 11_实时数据预处理_扩宽地域时间
- 12_实时数据预处理_扩宽isNew
- 13_实时数据预处理_扩宽isHourNew_isDayNew_isMonthNew
- 14_业务分析_实时频道热点
- 15_业务分析_实时频道热点_落地HBase
- 16_业务分析_频道小时维度PVUV
- 17_业务分析_频道天月维度PVUV
- 18_业务分析_用户新鲜度
- 19_业务分析_用户新鲜度_落地HBase
- 1_业务分析_模板方法抽取BaseTask
- 2_业务分析_重构新鲜度分析
- 3_业务分析_频道地域
- 4_业务分析_频道地域落地HBase
- 5_业务分析_运营商分析
- 6_业务分析_运营商分析_落地HBase
- 7_业务分析_浏览器分析
3-5 实时数据同步系统开发
- 8_实时同步系统介绍
- 9_采集方案_LogStash介绍
- 10_采集方案_Canal介绍
- 11_数据库采集系统介绍
- 12_MySql离线安装
- 13_MySql开启binlog
- 14_MySql主从复制介绍
- 15_Cananl原理介绍
- 16_Canal安装
- 17_Canal采集程序搭建【废弃待重录】
- 01_binlog说明
- 02_Flink实时同步应用开发介绍
- 03_项目初始化
- 04_Flink初始化
- 05_Flink整合Kafka
- 06_消息转换为Canal样例类
- 07_添加水印
- 08_HBaseOperation样例类
- 09_Canal转HBaseOperation介绍
- 10_PreprocessTask开发
- 11_Canal数据存储到HBase
3-6 Flink离线分析系统开发
- 12_离线分析系统简介
- 13_初始化Flink批处理环境
- 14_导入测试数据
- 15_整合HBase
- 16_测试读取HBase表数据_解决版本冲突
- 17_JSON转换为样例类
- 18_数据预处理_拓宽时间字段
- 19_业务分析_不同支付方式
- 20_业务分析_不同商家
- 21_项目总结