课程简介：

课程通过思路分析、画图演示、代码开发等多维方式，对数仓的构架过程及整体实现进行了详细的讲解。相较于实时数仓项目4.0，升级了项目架构设计和各个软件的版本，并采用GitFlow任务流的形式对整体项目进行版本控制，使用StreamPark对项目进行部署和监控。

课程目录：

| ├──001_课程介绍.mp4 42.09M
| ├──002_基础_数仓基本概念.mp4 20.32M
| ├──003_基础_离线数仓架构.mp4 15.46M
| ├──004_基础_实时数仓架构.mp4 50.38M
| ├──005_基础_ER模型和维度建模.mp4 68.90M
| ├──006_基础_事实表和维度表.mp4 90.49M
| ├──007_基础_数仓构建流程.mp4 130.29M
| ├──008_基础_项目架构以及代码版本控制方式介绍.mp4 137.65M
| ├──009_基础_IDEA开发环境搭建.mp4 114.30M
| ├──010_环境准备_GitLab的安装.mp4 96.29M
| ├──011_环境准备_GitLab的其它配置.mp4 94.73M
| ├──012_环境准备_创建用户以及群组.mp4 96.25M
| ├──013_环境准备_将初始代码推送到GitLab仓库.mp4 162.23M
| ├──014_环境准备_设置Kafka分区数.mp4 59.81M
| ├──015_ODS_日志数据采集.mp4 121.44M
| ├──016_ODS_配置binlog记录业务数据变化.mp4 130.75M
| ├──017_ODS_Maxwell的安装与配置.mp4 161.29M
| ├──018_ODS_Maxwell同步数据测试.mp4 103.86M
| ├──019_DIM_思路分析_基本流程.mp4 77.90M
| ├──020_DIM_思路分析_引入配置表.mp4 142.42M
| ├──021_DIM_思路分析_引入FlinkCDC.mp4 98.74M
| ├──022_DIM_思路分析_配置表字段完善.mp4 73.93M
| ├──023_DIM_FlinkCDC的使用.mp4 163.02M
| ├──024_DIM_配置表的创建以及切换开发分支.mp4 60.33M
| ├──025_DIM_开发思路分析.mp4 88.05M
| ├──026_DIM_基本环境准备以及检查点设置.mp4 121.12M
| ├──027_DIM_从Kafka主题中读取数据.mp4 148.83M
| ├──028_DIM_转换流中数据类型以及Maxwell问题说明.mp4 181.14M
| ├──029_DIM_使用FlinkCDC读取配置表数据.mp4 82.05M
| ├──030_DIM_将配置流数据类型封装为实体类对象.mp4 94.71M
| ├──031_DIM_封装HBaseUtil工具类.mp4 164.90M
| ├──032_DIM_在HBase中建表.mp4 118.42M
| ├──033_DIM_广播配置流并和主流进行关联.mp4 121.10M
| ├──034_DIM_处理广播流数据.mp4 78.74M
| ├──035_DIM_处理主流数据.mp4 142.95M
| ├──036_DIM_过滤掉不需要传递的字段.mp4 173.69M
| ├──037_DIM_主流数据先到问题分析.mp4 107.36M
| ├──038_DIM_在open方法中预加载配置信息.mp4 135.21M
| ├──039_DIM_将维度数据同步到HBase表中.mp4 227.04M
| ├──040_DIM_封装FlinkSourceUtil工具类.mp4 114.52M
| ├──041_DIM_抽取单独的处理函数类.mp4 111.49M
| ├──042_DIM_抽取BaseApp基类.mp4 173.83M
| ├──043_DIM_抽取方法.mp4 61.81M
| ├──044_DIM_封装JdbcUtil工具类.mp4 153.00M
| ├──045_DIM_DIM层总结.mp4 125.06M
| ├──046_DWD_DWD层介绍.mp4 49.85M
| ├──047_DWD_日志分流思路分析.mp4 71.82M
| ├──048_DWD_开发思路分析.mp4 74.36M
| ├──049_DWD_将脏数据放到侧输出流.mp4 99.93M
| ├──050_DWD_创建KafkaSink对象以及Kafka一致性保证.mp4 213.49M
| ├──051_DWD_抽取FlinkSinkUtil以及脏数据写到Kafka.mp4 41.31M
| ├──052_DWD_新老访客标记修复思路.mp4 112.61M
| ├──053_DWD_新老访客标记修复代码实现.mp4 154.22M
| ├──054_DWD_埋点日志结构分析.mp4 58.86M
| ├──055_DWD_分流代码实现.mp4 210.94M
| ├──056_DWD_将不同流的数据写到Kafka主题.mp4 87.34M
| ├──057_DWD_抽取方法以及提交代码到GitLab.mp4 132.18M
| ├──058_DWD_评论事实表思路分析.mp4 65.32M
| ├──059_DWD_FlinkAPI双流join介绍.mp4 233.53M
| ├──060_DWD_内连接.mp4 146.03M
| ├──061_DWD_左外连接.mp4 153.75M
| ├──062_DWD_右外连接以及全外连接.mp4 65.41M
| ├──063_DWD_左外连接结果写到kafka主题.mp4 154.64M
| ├──064_DWD_从Kafka主题中读取数据.mp4 81.39M
| ├──065_DWD_从HBase表中读取数据.mp4 91.68M
| ├──066_DWD_lookupJoin关联.mp4 173.43M
| ├──067_DWD_将关联结果写到Kafka主题.mp4 45.03M
| ├──068_DWD_评论事实表开发思路以及环境准备.mp4 104.48M
| ├──069_DWD_从topic_db主题中读取数据.mp4 101.86M
| ├──070_DWD_过滤出评论数据.mp4 127.28M
| ├──071_DWD_从Hbase中读取字典表数据.mp4 61.48M
| ├──072_DWD_关联评论表和字典表.mp4 66.48M
| ├──073_DWD_将关联的结果写到Kafka主题.mp4 67.58M
| ├──074_DWD_抽取工具类封装获取连接器属性的方法.mp4 122.83M
| ├──075_DWD_抽取BaseSQLApp基类以及通用的建表方法.mp4 181.12M
| ├──076_DWD_加购事实表开发思路分析.mp4 90.88M
| ├──077_DWD_过滤出insert类型的加购数据.mp4 80.68M
| ├──078_DWD_过滤出update类型的加购数据以及写到Kafka.mp4 120.96M
| ├──079_DWD_下单事实表思路分析.mp4 95.13M
| ├──080_DWD_下单事实表代码实现.mp4 174.59M
| ├──081_DWD_取消订单事实表整体实现.mp4 176.04M
| ├──082_DWD_支付成功事实表思路分析.mp4 128.59M
| ├──083_DWD_支付成功事实表代码实现.mp4 213.58M
| ├──084_DWD_退单事实表整体实现(了解业务).mp4 127.78M
| ├──085_DWD_退款成功事实表整体实现(了解业务).mp4 110.60M
| ├──086_DWD_其它事实表实现思路分析.mp4 83.49M
| ├──087_DWD_事实表动态分流思路.mp4 74.56M
| ├──088_DWD_开发思路分析.mp4 97.52M
| ├──089_DWD_业务数据以及配置表数据读取.mp4 124.31M
| ├──090_DWD_在open方法中预加载配置信息.mp4 106.96M
| ├──091_DWD_处理广播流中的配置信息.mp4 67.27M
| ├──092_DWD_处理主流中的业务数据.mp4 79.60M
| ├──093_DWD_将动态分流的事实表写到Kafka主题.mp4 172.10M
| ├──094_DWS层介绍.mp4 109.92M
| ├──095_Doris_Doris介绍.mp4 156.83M
| ├──096_Doris_安装前准备工作.mp4 144.64M
| ├──097_Doris_Doris安装以及FE的配置.mp4 128.09M
| ├──098_Doris_BE的配置.mp4 142.33M
| ├──099_Doris_FE与BE的扩容和缩容.mp4 122.32M
| ├──100_Doris_基本概念.mp4 59.52M
| ├──101_Doris_Aggregate 模型.mp4 90.06M
| ├──102_Doris_Unique模型和Duplicate模型.mp4 74.53M
| ├──103_Doris_建表其它操作.mp4 58.80M
| ├──104_Doris_Range分区.mp4 78.38M
| ├──105_Doris_List分区以及分区相关概念.mp4 139.03M
| ├──106_Doris_动态分区.mp4 208.45M
| ├──107_Doris_Rollup表.mp4 150.50M
| ├──108_Doris_物化视图.mp4 98.94M
| ├──109_Doris_Flink读写Doris_SQL.mp4 156.30M
| ├──110_Doris_Flink读写Doris_API.mp4 150.36M
| ├──111_DWS_搜索关键词思路分析.mp4 100.79M
| ├──112_DWS_分词工具类.mp4 76.78M
| ├──113_DWS_自定义UDTF函数.mp4 77.93M
| ├──114_DWS_开发思路分析.mp4 66.82M
| ├──115_DWS_读取页面日志数据创建动态表.mp4 130.05M
| ├──116_DWS_过滤出搜索行为.mp4 79.85M
| ├──117_DWS_分词并和原表字段进行关联.mp4 69.34M
| ├──118_DWS_分组、开窗、聚合计算.mp4 104.60M
| ├──119_DWS_将聚合结果写到Doris.mp4 163.40M
| ├──120_DWS_版本、渠道、地区、新老访客聚合统计思路分析.mp4 170.65M
| ├──121_DWS_读取数据并封装为统计的实体类对象.mp4 170.65M
| ├──122_DWS_指定Watermark的生成策略.mp4 55.87M
| ├──123_DWS_分组、开窗.mp4 179.64M
| ├──124_DWS_聚合.mp4 84.06M
| ├──125_DWS_将聚合结果写到Doris中.mp4 140.07M
| ├──126_DWS_首页、详情页聚合统计思路分析.mp4 91.95M
| ├──127_DWS_首页、详情页聚合统计代码实现.mp4 205.39M
| ├──128_DWS_独立用户以及回流用户聚合统计思路分析.mp4 105.66M
| ├──129_DWS_独立用户以及回流用户聚合统计代码实现.mp4 176.23M
| ├──130_DWS_加购独立用户思路分析.mp4 66.71M
| ├──131_DWS_加购独立用户代码实现.mp4 192.34M
| ├──132_DWS_sku粒度下单聚合统计需求分析.mp4 110.03M
| ├──133_DWS_sku粒度下单聚合统计开发思路.mp4 126.66M
| ├──134_DWS_从kafka中读取数据并转换为JSON对象.mp4 62.55M
| ├──135_DWS_状态+定时器实现去重.mp4 168.17M
| ├──136_DWS_状态+抵消实现去重.mp4 134.47M
| ├──137_DWS_封装为统计的实体类对象.mp4 95.74M
| ├──138_DWS_分组、开窗、聚合计算以及测试可能遇到的问题.mp4 114.73M
| ├──139_DWS_在HBaseUtil中封装查询维度的方法.mp4 187.19M
| ├──140_DWS_维度关联最基本的实现方式.mp4 129.87M
| ├──141_DWS_旁路缓存思路分析.mp4 84.14M
| ├──142_DWS_封装RedisUtil工具类.mp4 86.90M
| ├──143_DWS_在Redis工具类提供读写数据的方法.mp4 85.49M
| ├──144_DWS_旁路缓存代码实现.mp4 129.06M
| ├──145_DWS_维度数据发生变化清除缓存数据.mp4 88.94M
| ├──146_DWS_关联SPU维度.mp4 91.71M
| ├──147_DWS_抽取旁路缓存模板.mp4 125.59M
| ├──148_DWS_通过旁路缓存模板关联SKU维度.mp4 71.79M
| ├──149_DWS_异步IO介绍.mp4 127.70M
| ├──150_DWS_封装异步操作Redis的方法.mp4 83.00M
| ├──151_DWS_封装异步操作HBase的方法.mp4 108.60M
| ├──152_DWS_发送异步请求关联sku维度的基本实现.mp4 135.70M
| ├──153_DWS_发送异步请求关联spu维度以及抽取模板.mp4 91.54M
| ├──154_DWS_发送异步关联维度模板代码实现.mp4 186.47M
| ├──155_DWS_发送异步请求关联SKU维度.mp4 62.55M
| ├──156_DWS_关联其它维度并将结果写到Doris.mp4 163.96M
| ├──157_DWS_sku粒度下单聚合统计总结.mp4 209.51M
| ├──158_DWS_省份粒度下单聚合统计.mp4 71.00M
| ├──159_DWS_去重.mp4 119.00M
| ├──160_DWS_封装统计的实体类对象.mp4 87.71M
| ├──161_DWS_分组、开窗、聚合计算.mp4 52.78M
| ├──162_DWS_关联维度并将结果写到Doris.mp4 62.94M
| ├──163_ADS_ADS层介绍.mp4 83.99M
| ├──164_ADS_环境准备.mp4 153.09M
| ├──165_ADS_总交易额统计思路分析.mp4 86.28M
| ├──166_ADS_总交易额统计代码实现.mp4 130.20M
| ├──167_ADS_总交易额大屏展示.mp4 113.79M
| ├──168_ADS_省份交易额统计思路分析.mp4 68.08M
| ├──169_ADS_省份交易额统计代码实现.mp4 126.56M
| ├──170_ADS_渠道独立访客数统计思路分析.mp4 84.42M
| ├──171_ADS_渠道独立访客数统计代码实现.mp4 145.86M
| ├──172_ADS_渠道独立访客大屏展示以及常见错误避坑.mp4 125.26M
| ├──173_ADS_总交易额实时展示.mp4 241.15M
| ├──174_部署_打包.mp4 98.75M
| ├──175_部署_部署前准备工作.mp4 52.19M
| ├──176_部署_手动部署到服务器.mp4 232.54M
| ├──177_部署_StreamPark介绍.mp4 86.43M
| ├──178_部署_StreamPark安装.mp4 144.04M
| ├──179_部署_StreamPark其它配置.mp4 62.74M
| ├──180_部署_StreamPark中新建项目.mp4 51.46M
| ├──181_部署_构建项目.mp4 72.63M
| ├──182_部署_发布启动作业.mp4 116.22M
| ├──183_部署_合并分支.mp4 30.25M
| └──184_总结.mp4 178.85M
├──1.笔记.zip 42.68M
├──2.资料.zip 6.56G
└──3.代码.zip 0.46kb