课程试听
正在播放
第一章 就业课(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_项目总结