63. 采集模块-业务数据采集之读取MySQL数据并写入Kafka 编码 - 3

【尚硅谷】Flink数据仓库视频教程（一套精通实时数仓项目）

IT/互联网 / 程序设计开发

共292集 31.3万人观看

---

• 
  1课程介绍 - 1

  05:03
• 
  2课程介绍 - 3

  05:09
• 
  3项目介绍 - 1

  06:47
• 
  4项目介绍 - 3

  06:55
• 
  5采集模块-课程介绍

  04:56
• 
  6采集模块-数仓分层之为什么分层

  07:45
• 
  7采集模块-数仓分层之分层明细 - 1

  05:39
• 
  8采集模块-数仓分层之分层明细 - 3

  05:41
• 
  9采集模块-整体需求介绍 - 1

  08:47
• 
  10采集模块-整体需求介绍 - 3

  08:50
• 
  11采集模块-离线架构分析之Sqoop&Flume

  09:35
• 
  12采集模块-离线架构分析之FlumeTairDirSource问题提出&解决 - 1

  09:33
• 
  13采集模块-离线架构分析之FlumeTairDirSource问题提出&解决 - 3

  09:38
• 
  14采集模块-离线架构分析之Kafka - 1

  14:14
• 
  15采集模块-离线架构分析之Kafka - 3

  14:16
• 
  16采集模块-离线架构分析之其他

  07:55
• 
  17采集模块-实时架构分析 - 1

  06:00
• 
  18采集模块-实时架构分析 - 3

  06:12
• 
  19采集模块-架构对比 - 1

  05:25
• 
  20采集模块-架构对比 - 3

  05:21
• 
  21采集模块-日志数据采集之需求分析

  05:49
• 
  22采集模块-日志数据采集之MockJar包测试

  05:27
• 
  23采集模块-日志数据采集之SpringBoot简单介绍

  08:13
• 
  24采集模块-日志数据采集之SpringBoot创建项目&简单测试 - 1

  08:58
• 
  25采集模块-日志数据采集之SpringBoot创建项目&简单测试 - 3

  09:06
• 
  26采集模块-日志数据采集之SpringBoot创建项目&加参数测试

  03:45
• 
  27采集模块-日志数据采集之数据落盘&写入Kafka 编码 - 1

  07:55
• 
  28采集模块-日志数据采集之数据落盘&写入Kafka 编码 - 3

  07:58
• 
  29采集模块-日志数据采集之数据落盘&写入Kafka 本地测试

  05:05
• 
  30采集模块-日志数据采集之数据落盘&写入Kafka 单机测试

  04:57
• 
  31采集模块-日志数据采集之Nginx 介绍

  09:36
• 
  32采集模块-日志数据采集之Nginx 配置负载均衡&测试 - 1

  05:09
• 
  33采集模块-日志数据采集之Nginx 配置负载均衡&测试 - 3

  05:18
• 
  34采集模块-日志数据采集之集群测试 - 1

  06:30
• 
  35采集模块-日志数据采集之集群测试 - 3

  06:30
• 
  36采集模块-业务数据采集之建库&建表

  05:19
• 
  37采集模块-业务数据采集之FlinkCDC 什么是CDC&对比 - 1

  05:15
• 
  38采集模块-业务数据采集之FlinkCDC 什么是CDC&对比 - 3

  05:17
• 
  39采集模块-业务数据采集之FlinkCDC 介绍 - 1

  05:38
• 
  40采集模块-业务数据采集之FlinkCDC 介绍 - 3

  05:38
• 
  41采集模块-业务数据采集之FlinkCDC DataStream方式 编码 - 1

  10:48
• 
  42采集模块-业务数据采集之FlinkCDC DataStream方式 编码 - 3

  10:52
• 
  43采集模块-业务数据采集之FlinkCDC DataStream方式 测试 - 1

  05:19
• 
  44采集模块-业务数据采集之FlinkCDC DataStream方式 测试 - 3

  05:16
• 
  45采集模块-业务数据采集之FlinkCDC DataStreamAPI 设置CK&打包&开启集群 - 1

  08:29
• 
  46采集模块-业务数据采集之FlinkCDC DataStreamAPI 设置CK&打包&开启集群 - 3

  08:44
• 
  47采集模块-业务数据采集之FlinkCDC DataStreamAPI 打包进行断点续传测试 - 1

  06:08
• 
  48采集模块-业务数据采集之FlinkCDC DataStreamAPI 打包进行断点续传测试 - 3

  06:06
• 
  49采集模块-业务数据采集之FlinkCDC FlinkSQLAPI 编码&测试 - 1

  05:53
• 
  50采集模块-业务数据采集之FlinkCDC FlinkSQLAPI 编码&测试 - 3

  06:14
• 
  51采集模块-业务数据采集之FlinkCDC DataStreamAPI 自定义反序列化器 格式说明 - 1

  06:42
• 
  52采集模块-业务数据采集之FlinkCDC DataStreamAPI 自定义反序列化器 格式说明 - 3

  06:46
• 
  53采集模块-业务数据采集之FlinkCDC DataStreamAPI 自定义反序列化器 编码完成 - 1

  08:25
• 
  54采集模块-业务数据采集之FlinkCDC DataStreamAPI 自定义反序列化器 编码完成 - 3

  08:46
• 
  55采集模块-业务数据采集之FlinkCDC DataStreamAPI 自定义反序列化器 代码测试

  06:14
• 
  56采集模块-业务数据采集之FlinkCDC DataStreamAPI&FlinkSQL对比

  03:30
• 
  57采集模块-业务数据采集之Maxwell 安装说明&测试 - 1

  06:12
• 
  58采集模块-业务数据采集之Maxwell 安装说明&测试 - 3

  06:11
• 
  59采集模块-业务数据采集之Canal 安装说明&测试

  08:36
• 
  60采集模块-业务数据采集之CDC对比 - 1

  07:39
• 
  61采集模块-业务数据采集之CDC对比 - 3

  07:45
• 
  62采集模块-业务数据采集之读取MySQL数据并写入Kafka 编码 - 1

  05:55
• 
  63采集模块-业务数据采集之读取MySQL数据并写入Kafka 编码 - 3

  05:59
• 
  64采集模块-业务数据采集之读取MySQL数据并写入Kafka 测试

  04:39
• 
  65DWD&DIM-课程介绍

  06:15
• 
  66DWD&DIM-行为数据 需求分析

  09:51
• 
  67DWD&DIM-行为数据 思路整理&消费Kafka数据

  08:52
• 
  68DWD&DIM-行为数据 将数据转换为JSON对象

  08:15
• 
  69DWD&DIM-行为数据 新老用户校验 - 1

  05:43
• 
  70DWD&DIM-行为数据 新老用户校验 - 3

  05:43
• 
  71DWD&DIM-行为数据 侧输出流&写入Kafka - 1

  05:35
• 
  72DWD&DIM-行为数据 侧输出流&写入Kafka - 3

  05:35
• 
  73DWD&DIM-行为数据 测试 - 1

  05:24
• 
  74DWD&DIM-行为数据 测试 - 3

  05:22
• 
  75DWD&DIM-业务数据之需求分析 - 1

  14:21
• 
  76DWD&DIM-业务数据之需求分析 - 3

  14:17
• 
  77DWD&DIM-业务数据之代码逻辑梳理

  06:37
• 
  78DWD&DIM-业务数据之代码编写 消费数据并过滤

  05:01
• 
  79DWD&DIM-业务数据之代码编写 读取配置表创建广播流

  04:11
• 
  80DWD&DIM-业务数据之代码编写 配置表字段分析&建表&JavaBean - 1

  11:39
• 
  81DWD&DIM-业务数据之代码编写 配置表字段分析&建表&JavaBean - 3

  11:58
• 
  82DWD&DIM-业务数据之代码编写 开启配置表Binlog并测试

  04:47
• 
  83DWD&DIM-业务数据之代码编写 连接主流&广播流并分析业务逻辑

  08:34
• 
  84DWD&DIM-业务数据之代码编写 创建TableProcessFunction并初始化相关参数

  09:12
• 
  85DWD&DIM-业务数据之代码编写 处理广播流数据 解析数据&建表 - 1

  08:57
• 
  86DWD&DIM-业务数据之代码编写 处理广播流数据 解析数据&建表 - 3

  09:07
• 
  87DWD&DIM-业务数据之代码编写 处理广播流数据 写入状态

  01:10
• 
  88DWD&DIM-业务数据之代码编写 处理主流数据 读取状态&过滤字段 - 1

  08:37
• 
  89DWD&DIM-业务数据之代码编写 处理主流数据 读取状态&过滤字段 - 3

  08:51
• 
  90DWD&DIM-业务数据之代码编写 处理主流数据 补充SinkTable&分流

  05:15
• 
  91DWD&DIM-业务数据之代码编写 检查代码

  07:17
• 
  92DWD&DIM-业务数据之代码编写 测试准备

  08:20
• 
  93DWD&DIM-业务数据之代码编写 测试 - 1

  07:42
• 
  94DWD&DIM-业务数据之代码编写 测试 - 3

  07:39
• 
  95DWD&DIM-业务数据之代码编写 将数据写入HBase 编码 - 1

  13:47
• 
  96DWD&DIM-业务数据之代码编写 将数据写入HBase 编码 - 3

  13:58
• 
  97DWD&DIM-业务数据之代码编写 将数据写入Kafka 编码 - 1

  10:34
• 
  98DWD&DIM-业务数据之代码编写 将数据写入Kafka 编码 - 3

  10:35
• 
  99DWD&DIM-业务数据之整体测试 环境准备

  06:48
• 
  100DWD&DIM-业务数据之整体测试 测试完成 - 1

  07:38
• 
  101DWD&DIM-业务数据之整体测试 测试完成 - 3

  07:59
• 
  102ODS&DWD&DIM-小总结 - 1

  05:51
• 
  103ODS&DWD&DIM-小总结 - 3

  05:54
• 
  104ODS&DWD&DIM-SQL分享 需求说明&建表&导数据

  07:19
• 
  105ODS&DWD&DIM-SQL分享 方案二 - 1

  09:23
• 
  106ODS&DWD&DIM-SQL分享 方案二 - 3

  09:23
• 
  107ODS&DWD&DIM-SQL分享 HiveOnSpark Bug说明

  02:12
• 
  108DWM层-需求分析 - 1

  08:16
• 
  109DWM层-需求分析 - 3

  08:20
• 
  110DWM层-访客UV 需求分析

  09:29
• 
  111DWM层-访客UV 代码编写 消费数据并转换为JSON对象

  04:21
• 
  112DWM层-访客UV 代码编写 过滤数据 - 1

  07:40
• 
  113DWM层-访客UV 代码编写 过滤数据 - 3

  07:58
• 
  114DWM层-访客UV 代码编写 设置状态超时时间防止状态过大 - 1

  06:38
• 
  115DWM层-访客UV 代码编写 设置状态超时时间防止状态过大 - 3

  06:39
• 
  116DWM层-访客UV 代码测试

  08:18
• 
  117DWM层-跳出明细 需求分析 - 1

  06:14
• 
  118DWM层-跳出明细 需求分析 - 3

  06:12
• 
  119DWM层-跳出明细 代码编写 - 1

  07:48
• 
  120DWM层-跳出明细 代码编写 - 3

  07:45
• 
  121DWM层-跳出明细 代码测试 - 1

  06:12
• 
  122DWM层-跳出明细 代码测试 - 3

  06:12
• 
  123DWM层-跳出明细 测试

  07:55
• 
  124DWM层-跳出明细 CEP 循环模式

  03:08
• 
  125DWM层-订单宽表 需求分析

  05:25
• 
  126DWM层-订单宽表 双流JOIN 官方文档说明 - 1

  08:42
• 
  127DWM层-订单宽表 双流JOIN 官方文档说明 - 3

  08:48
• 
  128DWM层-订单宽表 双流JOIN 代码编写

  09:15
• 
  129DWM层-订单宽表 双流JOIN 代码测试 - 1

  06:13
• 
  130DWM层-订单宽表 双流JOIN 代码测试 - 3

  06:11
• 
  131DWM层-订单宽表 代码编写 消费Kafka数据&转换JavaBean&提取事件时间 - 1

  05:46
• 
  132DWM层-订单宽表 代码编写 消费Kafka数据&转换JavaBean&提取事件时间 - 3

  05:44
• 
  133DWM层-订单宽表 代码编写 订单与订单明细表双流JOIN

  09:13
• 
  134DWM层-订单宽表 代码测试 准备工作 - 1

  05:32
• 
  135DWM层-订单宽表 代码测试 准备工作 - 3

  05:38
• 
  136DWM层-订单宽表 代码测试 测试完成

  05:57
• 
  137DWM层-订单宽表 关联维度 思路梳理

  05:13
• 
  138DWM层-订单宽表 关联维度 JDBCUtil 返回值&参数说明

  09:39
• 
  139DWM层-订单宽表 关联维度 JDBCUtil 查询&封装泛型对象 - 1

  09:44
• 
  140DWM层-订单宽表 关联维度 JDBCUtil 查询&封装泛型对象 - 3

  09:41
• 
  141DWM层-订单宽表 关联维度 JDBCUtil 测试

  04:14
• 
  142DWM层-订单宽表 关联维度 DimUtil封装&优化的必要性 - 1

  07:56
• 
  143DWM层-订单宽表 关联维度 DimUtil封装&优化的必要性 - 3

  07:57
• 
  144DWM层-订单宽表 关联维度 优化1旁路缓存 思路分析 - 1

  05:28
• 
  145DWM层-订单宽表 关联维度 优化1旁路缓存 思路分析 - 3

  05:30
• 
  146DWM层-订单宽表 关联维度 优化1旁路缓存 Redis工具类&Key的设计 - 1

  07:49
• 
  147DWM层-订单宽表 关联维度 优化1旁路缓存 Redis工具类&Key的设计 - 3

  07:52
• 
  148DWM层-订单宽表 关联维度 优化1旁路缓存 代码编写 - 1

  06:52
• 
  149DWM层-订单宽表 关联维度 优化1旁路缓存 代码编写 - 3

  06:54
• 
  150DWM层-订单宽表 关联维度 优化1旁路缓存 代码测试

  08:29
• 
  151DWM层-订单宽表 回顾 - 1

  10:42
• 
  152DWM层-订单宽表 回顾 - 3

  10:48
• 
  153DWM层-订单宽表 关联维度 优化2 异步IO说明 - 1

  07:21
• 
  154DWM层-订单宽表 关联维度 优化2 异步IO说明 - 3

  07:24
• 
  155DWM层-订单宽表 关联维度 优化2 异步IO编码步骤

  04:51
• 
  156DWM层-订单宽表 关联维度 优化2 异步IO编码 初始化函数 - 1

  11:17
• 
  157DWM层-订单宽表 关联维度 优化2 异步IO编码 初始化函数 - 3

  11:40
• 
  158DWM层-订单宽表 关联维度 优化2 异步IO编码 异步函数完成 - 1

  12:00
• 
  159DWM层-订单宽表 关联维度 优化2 异步IO编码 异步函数完成 - 3

  12:04
• 
  160DWM层-订单宽表 关联维度 优化2 异步IO编码 测试准备 - 1

  08:53
• 
  161DWM层-订单宽表 关联维度 优化2 异步IO编码 测试准备 - 3

  08:51
• 
  162DWM层-订单宽表 关联维度 优化2 异步IO编码 测试完成

  09:52
• 
  163DWM层-订单宽表 关联维度 补充其他维度信息

  08:35
• 
  164DWM层-订单宽表 最终测试

  04:45
• 
  165DWM层-订单宽表 不丢维度数据说明

  06:35
• 
  166DWM层-支付宽表 需求分析

  09:30
• 
  167DWM层-支付宽表 代码编写 - 1

  07:56
• 
  168DWM层-支付宽表 代码编写 - 3

  08:01
• 
  169DWM层-支付宽表 代码测试

  08:39
• 
  170DWM层-支付宽表 时间工具类说明

  07:35
• 
  171DWS层-课程介绍

  05:29
• 
  172DWS层-访客主题宽表 需求分析 - 1

  06:53
• 
  173DWS层-访客主题宽表 需求分析 - 3

  07:05
• 
  174DWS层-访客主题宽表 思路整理&读取Kafka数据 - 1

  06:32
• 
  175DWS层-访客主题宽表 思路整理&读取Kafka数据 - 3

  06:37
• 
  176DWS层-访客主题宽表 处理输出流&union&提取时间戳分组 - 1

  08:37
• 
  177DWS层-访客主题宽表 处理输出流&union&提取时间戳分组 - 3

  08:38
• 
  178DWS层-访客主题宽表 开窗&聚合 - 1

  09:03
• 
  179DWS层-访客主题宽表 开窗&聚合 - 3

  09:12
• 
  180DWS层-访客主题宽表 打印测试 - 1

  08:38
• 
  181DWS层-访客主题宽表 打印测试 - 3

  08:54
• 
  182DWS层-ClickHouse 课程介绍

  03:42
• 
  183DWS层-ClickHouse 概述&特点 - 1

  06:37
• 
  184DWS层-ClickHouse 概述&特点 - 3

  06:43
• 
  185DWS层-ClickHouse 安装准备工作

  05:43
• 
  186DWS层-ClickHouse 安装&启动 - 1

  05:13
• 
  187DWS层-ClickHouse 安装&启动 - 3

  05:12
• 
  188DWS层-ClickHouse 数据类型 - 1

  08:25
• 
  189DWS层-ClickHouse 数据类型 - 3

  08:37
• 
  190DWS层-ClickHouse 简单引擎介绍

  04:32
• 
  191DWS层-ClickHouse MergeTree - 1

  05:18
• 
  192DWS层-ClickHouse MergeTree - 3

  05:17
• 
  193DWS层-ClickHouse MergeTree之Partition By

  06:02
• 
  194DWS层-ClickHouse MergeTree之Primary Key

  05:44
• 
  195DWS层-ClickHouse MergeTree之Order By

  04:19
• 
  196DWS层-ClickHouse MergeTree之TTL

  05:26
• 
  197DWS层-ClickHouse ReplacingMergeTree

  07:52
• 
  198DWS层-ClickHouse SummingMergeTree

  06:20
• 
  199DWS层-ClickHouse 引擎选择分析 - 1

  07:34
• 
  200DWS层-ClickHouse 引擎选择分析 - 3

  07:37
• 
  201DWS层-ClickHouse SQL操作 一 - 1

  06:51
• 
  202DWS层-ClickHouse SQL操作 一 - 3

  06:49
• 
  203DWS层-ClickHouse SQL操作 二 - 1

  11:33
• 
  204DWS层-ClickHouse SQL操作 二 - 3

  11:38
• 
  205DWS层-ClickHouse 副本机制 - 1

  05:39
• 
  206DWS层-ClickHouse 副本机制 - 3

  05:51
• 
  207DWS层-ClickHouse 分片机制 说明

  07:59
• 
  208DWS层-ClickHouse 分片机制 实操 - 1

  06:41
• 
  209DWS层-ClickHouse 分片机制 实操 - 3

  06:41
• 
  210DWS层-访客主题 ClickHouseUtil 创建 - 1

  06:40
• 
  211DWS层-访客主题 ClickHouseUtil 创建 - 3

  06:39
• 
  212DWS层-访客主题 ClickHouseUtil 封装 - 1

  06:06
• 
  213DWS层-访客主题 ClickHouseUtil 封装 - 3

  06:06
• 
  214DWS层-访客主题 ClickHouseUtil 封装完成 - 1

  09:16
• 
  215DWS层-访客主题 ClickHouseUtil 封装完成 - 3

  09:14
• 
  216DWS层-访客主题 ClickHouseUtil 测试完成

  09:24
• 
  217DWS层-商品主题 JavaBean说明

  08:30
• 
  218DWS层-商品主题 代码编写 思路整理&消费数据创建流

  07:51
• 
  219DWS层-商品主题 代码编写 处理页面日志&收藏数据&购物车数据 - 1

  08:33
• 
  220DWS层-商品主题 代码编写 处理页面日志&收藏数据&购物车数据 - 3

  08:29
• 
  221DWS层-商品主题 代码编写 处理订单&支付数据

  07:54
• 
  222DWS层-商品主题 代码编写 处理退单&评价数据

  08:51
• 
  223DWS层-商品主题 代码编写 分组开窗&聚合

  09:19
• 
  224DWS层-商品主题 代码编写 关联维度&将数据写入ClickHouse

  09:31
• 
  225DWS层-商品主题-整体测试 - 1

  10:50
• 
  226DWS层-商品主题-整体测试 - 3

  10:48
• 
  227DWS层-商品主题-需求分析

  05:10
• 
  228DWS层-商品主题 代码编写 创建环境&使用DDL方式读取Kafka数据 - 1

  11:23
• 
  229DWS层-商品主题 代码编写 创建环境&使用DDL方式读取Kafka数据 - 3

  11:39
• 
  230DWS层-商品主题 代码编写 分组开窗聚合 - 1

  05:16
• 
  231DWS层-商品主题 代码编写 分组开窗聚合 - 3

  05:18
• 
  232DWS层-商品主题 代码编写 将动态表转换为流并打印

  07:06
• 
  233DWS层-商品主题 代码编写 将数据写入ClickHouse&测试 - 1

  05:43
• 
  234DWS层-商品主题 代码编写 将数据写入ClickHouse&测试 - 3

  05:52
• 
  235DWS层-关键词主题 需求分析

  04:21
• 
  236DWS层-关键词主题 代码编写 分词工具类封装

  09:51
• 
  237DWS层-关键词主题 代码编写 分词UDTF - 1

  06:02
• 
  238DWS层-关键词主题 代码编写 分词UDTF - 3

  06:04
• 
  239DWS层-关键词主题 代码编写 思路分析&读取数据&建表 - 1

  08:30
• 
  240DWS层-关键词主题 代码编写 思路分析&读取数据&建表 - 3

  08:38
• 
  241DWS层-关键词主题 代码编写 分词&开窗聚合 - 1

  05:29
• 
  242DWS层-关键词主题 代码编写 分词&开窗聚合 - 3

  05:36
• 
  243DWS层-关键词主题 代码编写 动态表转换为流&写入ClickHouse

  09:10
• 
  244DWS层-关键词主题 代码测试

  04:06
• 
  245数据可视化-课程介绍

  07:35
• 
  246数据可视化-Sugar 创建大屏

  04:09
• 
  247数据可视化-Sugar 使用步骤介绍

  04:11
• 
  248数据可视化-数据接口 项目构建

  05:09
• 
  249数据可视化-数据接口 依赖导入&分层说明

  10:00
• 
  250数据可视化-数据接口 GMV接口 Mapper完成

  05:00
• 
  251数据可视化-数据接口 GMV接口 Service&Controller完成

  09:17
• 
  252数据可视化-数据接口 GMV接口 测试

  03:50
• 
  253数据可视化-数据接口 GMV接口 对接Sugar - 1

  07:01
• 
  254数据可视化-数据接口 GMV接口 对接Sugar - 3

  07:06
• 
  255数据可视化-数据接口 品牌GMV接口 Mapper完成 - 1

  06:22
• 
  256数据可视化-数据接口 品牌GMV接口 Mapper完成 - 3

  06:42
• 
  257数据可视化-数据接口 品牌GMV接口 Service完成

  05:40
• 
  258数据可视化-数据接口 品牌GMV接口 Controller完成

  03:47
• 
  259数据可视化-数据接口 品牌GMV接口 测试完成

  07:37
• 
  260数据可视化-数据接口 品牌GMV接口 对接Sugar

  03:39
• 
  261数据可视化-数据接口 导入代码&品类GMV&SPU GMV

  08:38
• 
  262数据可视化-数据接口 其他需求图表 - 1

  05:58
• 
  263数据可视化-数据接口 其他需求图表 - 3

  05:56
• 
  264数据可视化-最终测试 - 1

  06:46
• 
  265数据可视化-最终测试 - 3

  06:45
• 
  266Flink优化-课程介绍 - 1

  05:41
• 
  267Flink优化-课程介绍 - 3

  05:40
• 
  268Flink优化-资源优化之内存设置 - 1

  07:25
• 
  269Flink优化-资源优化之内存设置 - 3

  07:46
• 
  270Flink优化-资源优化之并行度设置 - 1

  05:49
• 
  271Flink优化-资源优化之并行度设置 - 3

  05:53
• 
  272Flink优化-资源优化之RockDB配置 - 1

  06:34
• 
  273Flink优化-资源优化之RockDB配置 - 3

  06:39
• 
  274Flink优化-资源优化之CheckPoint配置

  04:25
• 
  275Flink优化-资源优化之ParameterTool的介绍

  08:19
• 
  276Flink优化-反压处理之反压介绍&定位 - 1

  13:15
• 
  277Flink优化-反压处理之反压介绍&定位 - 3

  13:14
• 
  278Flink优化-反压处理之反压问题解决 - 1

  08:15
• 
  279Flink优化-反压处理之反压问题解决 - 3

  08:14
• 
  280Flink优化-数据倾斜之定位问题

  02:16
• 
  281Flink优化-数据倾斜之KeyBy之前的数据倾斜

  06:40
• 
  282Flink优化-数据倾斜之KeyBy之后直接聚合 - 1

  09:29
• 
  283Flink优化-数据倾斜之KeyBy之后直接聚合 - 3

  09:39
• 
  284Flink优化-数据倾斜之KeyBy之后开窗聚合 - 1

  07:51
• 
  285Flink优化-数据倾斜之KeyBy之后开窗聚合 - 3

  08:12
• 
  286Flink优化-FlinkSQL优化之MiniBatch

  08:41
• 
  287Flink优化-FlinkSQL优化之LocalGlobal

  03:39
• 
  288Flink优化-FlinkSQL优化之SplitDistinct

  03:34
• 
  289Flink优化-FlinkSQL优化之Agg With Filter

  01:38
• 
  290Flink优化-FlinkSQL优化之TopN优化 - 1

  05:06
• 
  291Flink优化-FlinkSQL优化之TopN优化 - 3

  05:18
• 
  292Flink优化-FlinkSQL优化之去重方案&其他

  05:37