黑马程序员大数据教程十天系统学习Spark分布式内存计算框架-21_入门案例WordCount：编程实现（上）-网易公开课

已购课程

个人中心 

内容中心

 关注我们

进入关怀模式

APP下载

反馈

21_入门案例WordCount：编程实现（上）

550 播放

下载

手机看

登录后可发评论

评论沙发是我的～

选集(387)

自动播放

[1] 02_Spark 课程说明（上）

1744播放

07:26

02_Spark 课程说明（上）

[2] 02_Spark 课程说明（下）

702播放

07:28

02_Spark 课程说明（下）

[3] 03_今日课程内容提纲（上）

1011播放

05:55

03_今日课程内容提纲（上）

[4] 03_今日课程内容提纲（下）

913播放

05:58

03_今日课程内容提纲（下）

[5] 04_Spark是什么（上）

673播放

09:58

04_Spark是什么（上）

[6] 04_Spark是什么（下）

1424播放

09:59

04_Spark是什么（下）

[7] 05_ Spark 四大特点（上）

1379播放

05:45

05_ Spark 四大特点（上）

[8] 05_ Spark 四大特点（下）

668播放

05:43

05_ Spark 四大特点（下）

[9] 06_Spark 框架模块（上）

991播放

05:29

06_Spark 框架模块（上）

[10] 06_Spark 框架模块（下）

808播放

05:35

06_Spark 框架模块（下）

[11] 07_Spark 运行模式

1262播放

05:57

07_Spark 运行模式

[12] 08_Spark 课程环境准备（虚...

932播放

09:29

08_Spark 课程环境准备（虚拟机）（上）

[13] 09_Spark 本地模式配置（上...

977播放

06:38

09_Spark 本地模式配置（上）

[14] 09_Spark 本地模式配置（下...

577播放

06:35

09_Spark 本地模式配置（下）

[15] 10_本地模式运行spark-sh...

677播放

08:39

10_本地模式运行spark-shell及测试（上）

[16] 10_本地模式运行spark-sh...

576播放

08:39

10_本地模式运行spark-shell及测试（下）

[17] 11_上午课程内容回顾（上）

1296播放

07:04

11_上午课程内容回顾（上）

[18] 11_上午课程内容回顾（下）

1244播放

07:07

11_上午课程内容回顾（下）

[19] 12_spark-shell运行词...

944播放

05:52

12_spark-shell运行词频统计WordCount(一）（上）

[20] 12_spark-shell运行词...

827播放

05:58

12_spark-shell运行词频统计WordCount(一）（下）

[21] 13_spark-shell运行词...

1242播放

08:20

13_spark-shell运行词频统计WordCount(二）（上）

[22] 13_spark-shell运行词...

1033播放

08:20

13_spark-shell运行词频统计WordCount(二）（下）

[23] 14_监控页面及圆周率PI运行

1331播放

07:14

14_监控页面及圆周率PI运行

[24] 15_Spark Standalo...

514播放

06:35

15_Spark Standalone集群架构（上）

[25] 15_Spark Standalo...

1356播放

06:40

15_Spark Standalone集群架构（下）

[26] 16_Spark Standalo...

1502播放

08:08

16_Spark Standalone集群部署测试（一）（上）

[27] 16_Spark Standalo...

1199播放

08:13

16_Spark Standalone集群部署测试（一）（下）

[28] 20_Spark Standalo...

1411播放

05:22

20_Spark Standalone HA高可用配置测试（上）

[29] 20_Spark Standalo...

777播放

05:21

20_Spark Standalone HA高可用配置测试（下）

[30] 22_Spark 应用开发：创建S...

916播放

07:03

22_Spark 应用开发：创建SparkContext对象

[31] 23_Spark 应用开发：词频统...

579播放

08:08

23_Spark 应用开发：词频统计Wordc编写测试

[32] 24_Spark 应用开发：词频统...

1329播放

05:52

24_Spark 应用开发：词频统计TopKey（一）

[33] 01_昨日课程内容回顾（一）（上）

751播放

08:59

01_昨日课程内容回顾（一）（上）

[34] 01_昨日课程内容回顾（一）（下）

1127播放

09:03

01_昨日课程内容回顾（一）（下）

[35] 02_昨日课程内容回顾（二）（上）

1081播放

06:27

02_昨日课程内容回顾（二）（上）

[36] 02_昨日课程内容回顾（二）（下）

869播放

06:29

02_昨日课程内容回顾（二）（下）

[37] 04_Spark 应用提交：spa...

579播放

06:33

04_Spark 应用提交：spark-submit命令参数（上）

[38] 04_Spark 应用提交：spa...

1303播放

06:29

04_Spark 应用提交：spark-submit命令参数（下）

[39] 05_Spark 应用提交：提交l...

639播放

09:27

05_Spark 应用提交：提交local和Standalone模式运行（上）

[40] 05_Spark 应用提交：提交l...

1273播放

09:29

05_Spark 应用提交：提交local和Standalone模式运行（下）

[41] 06_Spark on YARN：...

1214播放

08:28

06_Spark on YARN：参数配置和服务启动（上）

[42] 06_Spark on YARN：...

1295播放

08:29

06_Spark on YARN：参数配置和服务启动（下）

[43] 07_Spark on YARN：...

1128播放

05:26

07_Spark on YARN：提交运行PI和WordCount（上）

[44] 07_Spark on YARN：...

1021播放

05:30

07_Spark on YARN：提交运行PI和WordCount（下）

[45] 08_DeployMode部署模式...

1201播放

05:17

08_DeployMode部署模式：client和cluster区别（理论）

[46] 09_DeployMode部署模式...

1168播放

07:52

09_DeployMode部署模式：client和cluster演示（理Standalone集群）

[47] 11_上午内容复习回顾（上）

814播放

05:51

11_上午内容复习回顾（上）

[48] 11_上午内容复习回顾（下）

870播放

05:51

11_上午内容复习回顾（下）

[49] 12_YARN Client模式运...

995播放

07:03

12_YARN Client模式运行流程及演示（上）

[50] 12_YARN Client模式运...

790播放

07:04

12_YARN Client模式运行流程及演示（下）

[51] 13_YARN Cluster模式...

539播放

05:34

13_YARN Cluster模式运行流程及演示（上）

[52] 13_YARN Cluster模式...

982播放

05:33

13_YARN Cluster模式运行流程及演示（下）

[53] 14_Spark Applicat...

1492播放

06:13

14_Spark Application运行MAIN函数代码执行

[54] 16_RDD 概念：核心抽象及RD...

516播放

06:15

16_RDD 概念：核心抽象及RDD 论文（上）

[55] 16_RDD 概念：核心抽象及RD...

1208播放

06:16

16_RDD 概念：核心抽象及RDD 论文（下）

[56] 17_RDD 概念：RDD 定义（...

764播放

05:13

17_RDD 概念：RDD 定义（上）

[57] 17_RDD 概念：RDD 定义（...

1138播放

05:17

17_RDD 概念：RDD 定义（下）

[58] 18_RDD 概念：RDD 特性（...

618播放

07:01

18_RDD 概念：RDD 特性（上）

[59] 18_RDD 概念：RDD 特性（...

653播放

06:59

18_RDD 概念：RDD 特性（下）

[60] 19_RDD 概念：WordCou...

697播放

05:56

19_RDD 概念：WordCount中RDD（上）

[61] 19_RDD 概念：WordCou...

756播放

05:57

19_RDD 概念：WordCount中RDD（下）

[62] 20_RDD 创建：两种方式和并行...

1328播放

05:04

20_RDD 创建：两种方式和并行化集合（上）

[63] 20_RDD 创建：两种方式和并行...

578播放

05:08

20_RDD 创建：两种方式和并行化集合（下）

[64] 21_RDD 创建：外部存储系统和...

502播放

06:21

21_RDD 创建：外部存储系统和读取小文件（上）

[65] 21_RDD 创建：外部存储系统和...

914播放

06:19

21_RDD 创建：外部存储系统和读取小文件（下）

[66] 02_Spark 开发词频统计程序...

1027播放

08:06

02_Spark 开发词频统计程序（上）

[67] 02_Spark 开发词频统计程序...

522播放

08:10

02_Spark 开发词频统计程序（下）

[68] 04_分区操作函数mapParti...

1173播放

07:27

04_分区操作函数mapPartitions和foreachPartition（上）

[69] 04_分区操作函数mapParti...

1028播放

07:25

04_分区操作函数mapPartitions和foreachPartition（下）

[70] 05_重分区函数repartiti...

1394播放

05:13

05_重分区函数repartition和coalesce（上）

[71] 05_重分区函数repartiti...

923播放

05:13

05_重分区函数repartition和coalesce（下）

[72] 07_RDD中聚合函数reduce...

1453播放

06:11

07_RDD中聚合函数reduce和fold（上）

[73] 07_RDD中聚合函数reduce...

664播放

06:14

07_RDD中聚合函数reduce和fold（下）

[74] 08_RDD中聚合函数aggreg...

1256播放

07:42

08_RDD中聚合函数aggregate（上）

[75] 08_RDD中聚合函数aggreg...

1241播放

07:39

08_RDD中聚合函数aggregate（下）

[76] 09_PairRDDFunctio...

787播放

06:48

09_PairRDDFunctions中聚合函数（上）

[77] 09_PairRDDFunctio...

1178播放

06:52

09_PairRDDFunctions中聚合函数（下）

[78] 10_RDD 关联函数（上）

625播放

06:47

10_RDD 关联函数（上）

[79] 10_RDD 关联函数（下）

899播放

06:43

10_RDD 关联函数（下）

[80] 11_RDD 函数练习

610播放

02:55

11_RDD 函数练习

[81] 12_RDD 持久化（上）

770播放

07:08

12_RDD 持久化（上）

[82] 12_RDD 持久化（下）

1403播放

07:13

12_RDD 持久化（下）

[83] 13_上午课程内容回顾（上）

882播放

07:57

13_上午课程内容回顾（上）

[84] 13_上午课程内容回顾（下）

1377播放

07:54

13_上午课程内容回顾（下）

[85] 黑马程序员大数据教程十天系统学习S...

811播放

06:06

黑马程序员大数据教程十天系统学习Spark分布式内存计算框架(60)（上）

[86] 黑马程序员大数据教程十天系统学习S...

694播放

06:07

黑马程序员大数据教程十天系统学习Spark分布式内存计算框架(60)（下）

[87] 15_SogouQ日志分析：数据调...

796播放

08:08

15_SogouQ日志分析：数据调研和业务分析

[88] 16_SogouQ日志分析：Han...

1202播放

05:23

16_SogouQ日志分析：HanLP 中文分词（上）

[89] 16_SogouQ日志分析：Han...

616播放

05:24

16_SogouQ日志分析：HanLP 中文分词（下）

[90] 17_SogouQ日志分析：读取数...

624播放

06:12

17_SogouQ日志分析：读取数据封装SogouRecord（上）

[91] 17_SogouQ日志分析：读取数...

743播放

06:15

17_SogouQ日志分析：读取数据封装SogouRecord（下）

[92] 18_SogouQ日志分析：搜索关...

825播放

05:51

18_SogouQ日志分析：搜索关键词统计（上）

[93] 18_SogouQ日志分析：搜索关...

580播放

05:51

18_SogouQ日志分析：搜索关键词统计（下）

[94] 19_SogouQ日志分析：用户搜...

884播放

08:29

19_SogouQ日志分析：用户搜索点击统计

[95] 20_SogouQ日志分析：搜索时...

1052播放

06:36

20_SogouQ日志分析：搜索时间段统计

[96] 21_外部数据源：综合概述

679播放

08:41

21_外部数据源：综合概述

[97] 22_外部数据源：Spark与HB...

1495播放

05:31

22_外部数据源：Spark与HBase交互概述

[98] 23_外部数据源：HBase Si...

948播放

09:01

23_外部数据源：HBase Sink（上）

[99] 23_外部数据源：HBase Si...

1272播放

08:59

23_外部数据源：HBase Sink（下）

[100] 24_外部数据源：HBase So...

1090播放

09:10

24_外部数据源：HBase Source（上）

[101] 24_外部数据源：HBase So...

1040播放

09:10

24_外部数据源：HBase Source（下）

[102] 02_RDD 共享变量：含义及案例...

959播放

06:03

02_RDD 共享变量：含义及案例需求说明（上）

[103] 02_RDD 共享变量：含义及案例...

738播放

06:00

02_RDD 共享变量：含义及案例需求说明（下）

[104] 03_共享变量：编程实现非单词过滤...

693播放

07:26

03_共享变量：编程实现非单词过滤（上）

[105] 03_共享变量：编程实现非单词过滤...

689播放

07:26

03_共享变量：编程实现非单词过滤（下）

[106] 04_Spark框架中各个模块的数...

1276播放

06:57

04_Spark框架中各个模块的数据结构抽象（上）

[107] 04_Spark框架中各个模块的数...

1486播放

06:53

04_Spark框架中各个模块的数据结构抽象（下）

[108] 05_今日课程内容提纲

1026播放

08:28

05_今日课程内容提纲

[109] 06_SparkSession应用...

752播放

07:05

06_SparkSession应用入口（上）

[110] 06_SparkSession应用...

581播放

07:11

06_SparkSession应用入口（下）

[111] 07_词频统计WordCount：...

1285播放

05:39

07_词频统计WordCount：基于DSL编程（上）

[112] 07_词频统计WordCount：...

1265播放

05:44

07_词频统计WordCount：基于DSL编程（下）

[113] 08_词频统计WordCount：...

1042播放

09:55

08_词频统计WordCount：基于SQL编程

[114] 09_SparkSQL 前世今生（...

950播放

09:55

09_SparkSQL 前世今生（上）

[115] 09_SparkSQL 前世今生（...

876播放

10:00

09_SparkSQL 前世今生（下）

[116] 10_SparkSQL官方定义和特...

1293播放

07:32

10_SparkSQL官方定义和特性

[117] 11_DataFrame是什么（上...

1297播放

06:45

11_DataFrame是什么（上）

[118] 11_DataFrame是什么（下...

599播放

06:49

11_DataFrame是什么（下）

[119] 12_DataFrame中Sche...

1100播放

02:21

12_DataFrame中Schema

[120] 14_上午课程内容回顾（上）

1279播放

07:04

14_上午课程内容回顾（上）

[121] 14_上午课程内容回顾（下）

593播放

07:02

14_上午课程内容回顾（下）

[122] 15_RDD转换DataFrame...

1376播放

07:22

15_RDD转换DataFrame：综合概述

[123] 16_RDD转换DataFrame...

885播放

09:45

16_RDD转换DataFrame：反射类型推断

[124] 18_toDF函数指定列名称转换为...

628播放

09:07

18_toDF函数指定列名称转换为DataFrame

[125] 19_基于DSL分析（函数说明）和...

1062播放

09:46

19_基于DSL分析（函数说明）和SQL分析

[126] 20_电影评分数据分析：需求说明

703播放

06:23

20_电影评分数据分析：需求说明

[127] 21_电影评分数据分析：数据ETL

1359播放

05:43

21_电影评分数据分析：数据ETL

[128] 22_电影评分数据分析：SQL分析

959播放

06:47

22_电影评分数据分析：SQL分析

[129] 23_电影评分数据分析：DSL分析

1044播放

09:19

23_电影评分数据分析：DSL分析

[130] 24_电影评分数据分析：保存结果至...

1233播放

09:25

24_电影评分数据分析：保存结果至MySQL和CSV文件

[131] 25_电影评分数据分析：Spark...

1264播放

04:48

25_电影评分数据分析：SparkSQL中Shuffle分区数

[132] 26_Dataset 是什么

781播放

07:02

26_Dataset 是什么

[133] 29_外部数据源：加载load和保...

1371播放

06:16

29_外部数据源：加载load和保存save数据（上）

[134] 29_外部数据源：加载load和保...

1104播放

06:17

29_外部数据源：加载load和保存save数据（下）

[135] 31_外部数据源：集成Hive概述

1409播放

06:59

31_外部数据源：集成Hive概述

[136] 32_外部数据源：集成Hive（s...

820播放

07:29

32_外部数据源：集成Hive（spark-shell）

[137] 33_外部数据源：集成Hive（I...

931播放

07:24

33_外部数据源：集成Hive（IDEA开发）

[138] 34_自定义UDF函数在SQL和D...

1196播放

05:05

34_自定义UDF函数在SQL和DSL中使用（上）

[139] 01_昨日课程内容回顾：核心要点（...

1173播放

06:36

01_昨日课程内容回顾：核心要点（上）

[140] 01_昨日课程内容回顾：核心要点（...

1436播放

06:35

01_昨日课程内容回顾：核心要点（下）

[141] 02_昨日课程内容回顾：思维导图（...

1341播放

10:15

02_昨日课程内容回顾：思维导图（上）

[142] 02_昨日课程内容回顾：思维导图（...

1130播放

10:15

02_昨日课程内容回顾：思维导图（下）

[143] 03_分布式SQL引擎：spark...

511播放

08:13

03_分布式SQL引擎：spark-sql交互式命令行使用

[144] 04_分布式SQL引擎：启动Thr...

578播放

06:13

04_分布式SQL引擎：启动ThriftServer服务和beeline连接

[145] 06_离线数据分析流程（五步）

1495播放

08:10

06_离线数据分析流程（五步）

[146] 08_综合实战业务背景和需求概述（...

579播放

08:51

08_综合实战业务背景和需求概述（上）

[147] 08_综合实战业务背景和需求概述（...

785播放

08:49

08_综合实战业务背景和需求概述（下）

[148] 09_数据调研和业务需求（上）

696播放

05:40

09_数据调研和业务需求（上）

[149] 09_数据调研和业务需求（下）

567播放

05:42

09_数据调研和业务需求（下）

[150] 10_环境搭建：大数据环境

572播放

09:07

10_环境搭建：大数据环境

[151] 11_环境搭建：应用开发环境

780播放

07:12

11_环境搭建：应用开发环境

[152] 12_项目初始化：属性文件和工具类

541播放

07:09

12_项目初始化：属性文件和工具类

[153] 13_项目初始化：加载属性文件

1297播放

08:43

13_项目初始化：加载属性文件

[154] 14_项目初始化：SparkSes...

756播放

06:32

14_项目初始化：SparkSession 工具类（上）

[155] 14_项目初始化：SparkSes...

629播放

06:35

14_项目初始化：SparkSession 工具类（下）

[156] 15_项目初始化：记录日志和配置l...

672播放

06:40

15_项目初始化：记录日志和配置log4j.properties文件

[157] 16_广告数据ETL：IP地址解析...

1096播放

05:08

16_广告数据ETL：IP地址解析（上）

[158] 16_广告数据ETL：IP地址解析...

1191播放

05:09

16_广告数据ETL：IP地址解析（下）

[159] 17_广告数据ETL：IP 工具类

1159播放

06:14

17_广告数据ETL：IP 工具类

[160] 18_广告数据ETL：Hive表创...

1125播放

08:02

18_广告数据ETL：Hive表创建（上）

[161] 18_广告数据ETL：Hive表创...

1340播放

07:58

18_广告数据ETL：Hive表创建（下）

[162] 21_广告数据ETL：数据ETL（...

1485播放

07:26

21_广告数据ETL：数据ETL（一）（上）

[163] 21_广告数据ETL：数据ETL（...

1022播放

07:30

21_广告数据ETL：数据ETL（一）（下）

[164] 22_广告数据ETL：数据ETL（...

605播放

03:29

22_广告数据ETL：数据ETL（二）

[165] 23_广告数据ETL：数据ETL（...

1113播放

08:08

23_广告数据ETL：数据ETL（三）

[166] 24_广告数据ETL：数据ETL（...

1301播放

06:53

24_广告数据ETL：数据ETL（四）（上）

[167] 24_广告数据ETL：数据ETL（...

1398播放

06:52

24_广告数据ETL：数据ETL（四）（下）

[168] 25_广告数据ETL：Spark ...

838播放

07:38

25_广告数据ETL：Spark 分布式缓存

[169] 26_广告数据ETL：Spark ...

531播放

05:08

26_广告数据ETL：Spark on Hive与Hive on Spark区别

[170] 27_业务报表分析：业务需求

761播放

04:33

27_业务报表分析：业务需求

[171] 28_业务报表分析：报表运行主类（...

788播放

05:20

28_业务报表分析：报表运行主类（上）

[172] 28_业务报表分析：报表运行主类（...

521播放

05:23

28_业务报表分析：报表运行主类（下）

[173] 29_业务报表分析：各地域数量分布...

830播放

04:44

29_业务报表分析：各地域数量分布（一）

[174] 30_业务报表分析：各地域数量分布...

537播放

05:47

30_业务报表分析：各地域数量分布（二）（上）

[175] 30_业务报表分析：各地域数量分布...

1130播放

05:47

30_业务报表分析：各地域数量分布（二）（下）

[176] 31_业务报表分析：各地域数量分布...

580播放

07:21

31_业务报表分析：各地域数量分布（三）（上）

[177] 31_业务报表分析：各地域数量分布...

1384播放

07:28

31_业务报表分析：各地域数量分布（三）（下）

[178] 32_业务报表分析：各地域数量分布...

1209播放

09:31

32_业务报表分析：各地域数量分布（四）

[179] 33_广告投放的地域分布（一）

836播放

05:43

33_广告投放的地域分布（一）

[180] 34_广告投放的地域分布（二）（上...

1369播放

05:11

34_广告投放的地域分布（二）（上）

[181] 34_广告投放的地域分布（二）（下...

615播放

05:15

34_广告投放的地域分布（二）（下）

[182] 35_广告投放的地域分布（三）（上...

986播放

08:23

35_广告投放的地域分布（三）（上）

[183] 35_广告投放的地域分布（三）（下...

1165播放

08:27

35_广告投放的地域分布（三）（下）

[184] 03_广告投放的地域分布（五）（上...

1178播放

09:58

03_广告投放的地域分布（五）（上）

[185] 03_广告投放的地域分布（五）（下...

1236播放

09:56

03_广告投放的地域分布（五）（下）

[186] 04_广告投放其他维度分析

789播放

07:36

04_广告投放其他维度分析

[187] 05_应用提交：应用开发测试概述

1302播放

03:22

05_应用提交：应用开发测试概述

[188] 06_应用提交：应用打包（上）

837播放

05:38

06_应用提交：应用打包（上）

[189] 06_应用提交：应用打包（下）

819播放

05:36

06_应用提交：应用打包（下）

[190] 07_应用提交：删除分区数据和报表...

509播放

03:02

07_应用提交：删除分区数据和报表数据

[191] 08_集群提交运行（本地模式）（上...

1270播放

07:10

08_集群提交运行（本地模式）（上）

[192] 08_集群提交运行（本地模式）（下...

671播放

07:09

08_集群提交运行（本地模式）（下）

[193] 09_集群提交运行（集群模式）（上...

854播放

08:16

09_集群提交运行（集群模式）（上）

[194] 09_集群提交运行（集群模式）（下...

1221播放

08:18

09_集群提交运行（集群模式）（下）

[195] 10_Oozie 集成 Spark...

688播放

05:32

10_Oozie 集成 Spark2 安装配置（上）

[196] 10_Oozie 集成 Spark...

710播放

05:29

10_Oozie 集成 Spark2 安装配置（下）

[197] 11_Oozie 调度框架回顾（上...

528播放

08:20

11_Oozie 调度框架回顾（上）

[198] 11_Oozie 调度框架回顾（下...

708播放

08:17

11_Oozie 调度框架回顾（下）

[199] 12_Oozie 调度 Spark...

1213播放

07:56

12_Oozie 调度 Spark2应用（上）

[200] 12_Oozie 调度 Spark...

1334播放

07:56

12_Oozie 调度 Spark2应用（下）

[201] 13_深入剖析Oozie 组件及运...

1288播放

14:59

13_深入剖析Oozie 组件及运行本质和配置（上）

[202] 13_深入剖析Oozie 组件及运...

1047播放

14:59

13_深入剖析Oozie 组件及运行本质和配置（下）

[203] 14_Hue 创建 Oozie 工...

746播放

08:12

14_Hue 创建 Oozie 工作流（上）

[204] 14_Hue 创建 Oozie 工...

1212播放

08:11

14_Hue 创建 Oozie 工作流（下）

[205] 15_Oozie 调度应用：调度【...

937播放

06:29

15_Oozie 调度应用：调度【ETL 应用】（上）

[206] 15_Oozie 调度应用：调度【...

977播放

06:25

15_Oozie 调度应用：调度【ETL 应用】（下）

[207] 16_Oozie 调度应用：调度【...

1061播放

07:32

16_Oozie 调度应用：调度【报表应用】

[208] 17_Hue创建Oozie Wor...

945播放

08:35

17_Hue创建Oozie WorkFlow：ETL 应用

[209] 18_Hue创建Oozie Wor...

1284播放

06:11

18_Hue创建Oozie WorkFlow：报表应用

[210] 19_Hue创建Oozie Coo...

1275播放

05:25

19_Hue创建Oozie Coordinator：ETL 应用（上）

[211] 19_Hue创建Oozie Coo...

778播放

05:30

19_Hue创建Oozie Coordinator：ETL 应用（下）

[212] 20_Hue创建Oozie Coo...

854播放

05:49

20_Hue创建Oozie Coordinator：报表应用

[213] 21_Spark 内核调度：引例W...

748播放

08:05

21_Spark 内核调度：引例WordCount

[214] 22_Spark 内核调度：RDD...

1298播放

09:23

22_Spark 内核调度：RDD 依赖

[215] 23_Spark 内核调度：DAG...

1125播放

06:57

23_Spark 内核调度：DAG和Stage

[216] 26_Spark 内核调度：Spa...

738播放

06:25

26_Spark 内核调度：Spark 基本概念

[217] 27_Spark 并行度（一）

815播放

04:10

27_Spark 并行度（一）

[218] 28_Spark 并行度（一）

1040播放

08:58

28_Spark 并行度（一）

[219] 01_Spark框架中流式处理模块...

1159播放

08:15

01_Spark框架中流式处理模块和四大流式计算框架（上）

[220] 01_Spark框架中流式处理模块...

645播放

08:15

01_Spark框架中流式处理模块和四大流式计算框架（下）

[221] 02_今日课程内容提纲（上）

1106播放

05:21

02_今日课程内容提纲（上）

[222] 02_今日课程内容提纲（下）

800播放

05:24

02_今日课程内容提纲（下）

[223] 03_Straming 概述：流式...

649播放

05:19

03_Straming 概述：流式应用场景（上）

[224] 03_Straming 概述：流式...

1282播放

05:22

03_Straming 概述：流式应用场景（下）

[225] 04_Straming 概述：La...

1054播放

05:04

04_Straming 概述：Lambda架构（上）

[226] 04_Straming 概述：La...

691播放

05:04

04_Straming 概述：Lambda架构（下）

[227] 05_Straming 概述：流式...

902播放

06:06

05_Straming 概述：流式数据计算模式（上）

[228] 05_Straming 概述：流式...

713播放

06:06

05_Straming 概述：流式数据计算模式（下）

[229] 06_Straming 概述：Sp...

743播放

09:05

06_Straming 概述：SparkStreaming计算思想

[230] 07_官方案例运行：每批次词频统计...

1494播放

09:27

07_官方案例运行：每批次词频统计WordCount

[231] 08_入门案例：Streaming...

1473播放

08:25

08_入门案例：Streaming编程模块

[232] 09_入门案例：代码实现及测试运行

1173播放

09:43

09_入门案例：代码实现及测试运行

[233] 10_入门案例：Streaming...

1225播放

07:59

10_入门案例：Streaming 应用监控

[234] 11_SparkStreaming...

973播放

09:41

11_SparkStreaming 运行工作原理（上）

[235] 11_SparkStreaming...

739播放

09:46

11_SparkStreaming 运行工作原理（下）

[236] 12_BatchInterval和...

1493播放

05:32

12_BatchInterval和BlockInterval

[237] 14_DStream 是什么

781播放

06:50

14_DStream 是什么

[238] 15_DStream Operat...

563播放

07:09

15_DStream Operations函数概述

[239] 15_DStream中针对RDD操...

761播放

02:00

15_DStream中针对RDD操作函数说明

[240] 16_DStream中transf...

523播放

05:17

16_DStream中transform函数使用

[241] 17_DStream中foreac...

823播放

07:30

17_DStream中foreachRDD函数使用

[242] 18_上午课程内容回顾

694播放

09:25

18_上午课程内容回顾

[243] 19_SparkStreaming...

1335播放

06:57

19_SparkStreaming流式应用三种状态（一）

[244] 20_SparkStreaming...

1078播放

05:37

20_SparkStreaming流式应用三种状态（二）（上）

[245] 20_SparkStreaming...

937播放

05:40

20_SparkStreaming流式应用三种状态（二）（下）

[246] 21_流式应用技术栈及Kafka面...

916播放

06:39

21_流式应用技术栈及Kafka面试题

[247] 22_SparkStreaming...

903播放

07:50

22_SparkStreaming集成Kafka两种方式（Old和New Consumer API）（上）

[248] 22_SparkStreaming...

563播放

07:55

22_SparkStreaming集成Kafka两种方式（Old和New Consumer API）（下）

[249] 23_集成Kafk aOld Co...

510播放

05:24

23_集成Kafk aOld Consumer API两种区别

[250] 24_Old Consumer A...

1383播放

11:17

24_Old Consumer API中Direct 方式集成：编程实现（上）

[251] 24_Old Consumer A...

842播放

11:15

24_Old Consumer API中Direct 方式集成：编程实现（下）

[252] 25_Old Consumer A...

1337播放

05:10

25_Old Consumer API中Direct 方式集成：底层原理及最大数据量（上）

[253] 25_Old Consumer A...

711播放

05:15

25_Old Consumer API中Direct 方式集成：底层原理及最大数据量（下）

[254] 26_New Consumer A...

1387播放

06:42

26_New Consumer API方式集成编程（上）

[255] 26_New Consumer A...

1012播放

06:43

26_New Consumer API方式集成编程（下）

[256] 27_集成Kafka时获取消费偏移...

607播放

06:49

27_集成Kafka时获取消费偏移量信息（上）

[257] 27_集成Kafka时获取消费偏移...

1345播放

06:55

27_集成Kafka时获取消费偏移量信息（下）

[258] 28_应用案例：业务场景和需求说明

1005播放

07:15

28_应用案例：业务场景和需求说明

[259] 29_应用案例：初始化环境

1049播放

07:49

29_应用案例：初始化环境

[260] 30_应用案例：Streaming...

937播放

04:08

30_应用案例：StreamingContextUtils 工具类

[261] 31_应用案例：实时数据ETL存储...

898播放

10:34

31_应用案例：实时数据ETL存储（上）

[262] 31_应用案例：实时数据ETL存储...

670播放

10:41

31_应用案例：实时数据ETL存储（下）

[263] 32_应用案例：updateSta...

545播放

13:43

32_应用案例：updateStateByKey 函数（上）

[264] 32_应用案例：updateSta...

1171播放

13:45

32_应用案例：updateStateByKey 函数（下）

[265] 02_昨日课程内容回顾：集成Kaf...

726播放

07:46

02_昨日课程内容回顾：集成Kafka（上）

[266] 02_昨日课程内容回顾：集成Kaf...

1038播放

07:42

02_昨日课程内容回顾：集成Kafka（下）

[267] 03_昨日课程内容回顾：无状态和有...

1313播放

07:23

03_昨日课程内容回顾：无状态和有状态计算（上）

[268] 03_昨日课程内容回顾：无状态和有...

583播放

07:25

03_昨日课程内容回顾：无状态和有状态计算（下）

[269] 04_应用案例：实时窗口统计win...

702播放

10:46

04_应用案例：实时窗口统计window（上）

[270] 04_应用案例：实时窗口统计win...

766播放

10:46

04_应用案例：实时窗口统计window（下）

[271] 05_应用案例：实时窗口统计red...

954播放

06:55

05_应用案例：实时窗口统计reduceByKeyAndWindow（上）

[272] 05_应用案例：实时窗口统计red...

868播放

06:56

05_应用案例：实时窗口统计reduceByKeyAndWindow（下）

[273] 06_偏移量管理：概述及Check...

922播放

05:32

06_偏移量管理：概述及Checkpoint原理（上）

[274] 06_偏移量管理：概述及Check...

695播放

05:39

06_偏移量管理：概述及Checkpoint原理（下）

[275] 07_偏移量管理：重构代码

1090播放

07:11

07_偏移量管理：重构代码

[276] 08_偏移量管理：Checkpoi...

698播放

07:13

08_偏移量管理：Checkpoint编码实现（上）

[277] 08_偏移量管理：Checkpoi...

977播放

07:13

08_偏移量管理：Checkpoint编码实现（下）

[278] 10_偏移量管理：MySQL 存储...

1257播放

09:15

10_偏移量管理：MySQL 存储偏移量（一）

[279] 11_偏移量管理：MySQL 存储...

519播放

09:05

11_偏移量管理：MySQL 存储偏移量（二）（上）

[280] 11_偏移量管理：MySQL 存储...

618播放

09:09

11_偏移量管理：MySQL 存储偏移量（二）（下）

[281] 12_偏移量管理：Kafka 自身...

578播放

09:26

12_偏移量管理：Kafka 自身管理（异步提交偏移量）

[282] 13_Structured Str...

1018播放

05:33

13_Structured Streaming结构化流模块综合概述（上）

[283] 13_Structured Str...

1417播放

05:33

13_Structured Streaming结构化流模块综合概述（下）

[284] 16_Structured Str...

1483播放

06:07

16_Structured Streaming 概述：模块介绍和核心思想

[285] 17_Structured Str...

511播放

07:56

17_Structured Streaming 概述：编程模型

[286] 18_StructuredStre...

1353播放

04:42

18_StructuredStreaming概述：编程模型（二）

[287] 19_入门案例WordCount：...

657播放

07:24

19_入门案例WordCount：功能演示

[288] 20_入门案例WordCount：...

1248播放

04:38

20_入门案例WordCount：Socket数据源和Console接收器

[289] 21_入门案例WordCount：...

550播放

待播放

21_入门案例WordCount：编程实现（上）

[290] 21_入门案例WordCount：...

946播放

08:54

21_入门案例WordCount：编程实现（下）

[291] 22_Input Sources ...

1414播放

09:15

22_Input Sources 输入源概述及File 数据源

[292] 23_Rate source数据源

1324播放

03:56

23_Rate source数据源

[293] 24_Streaming Quer...

1259播放

07:47

24_Streaming Queries基本设置（名称、触发、检查点及输出模式）（上）

[294] 24_Streaming Quer...

1069播放

07:51

24_Streaming Queries基本设置（名称、触发、检查点及输出模式）（下）

[295] 25_输出终端Sink概述

701播放

05:23

25_输出终端Sink概述

[296] 26_输出函数foreach使用（...

1249播放

06:07

26_输出函数foreach使用（上）

[297] 26_输出函数foreach使用（...

1246播放

06:10

26_输出函数foreach使用（下）

[298] 27_输出函数foreachBat...

828播放

07:20

27_输出函数foreachBatch使用

[299] 28_StructuredStre...

1178播放

08:18

28_StructuredStreaming如何保证容错语义

[300] 29_集成Kafka概述及Kafk...

1436播放

07:30

29_集成Kafka概述及Kafka 消费数据

[301] 30_集成Kafka：Kafka ...

549播放

09:25

30_集成Kafka：Kafka 数据源

[302] 31_集成Kafka：实时数据ET...

949播放

05:51

31_集成Kafka：实时数据ETL架构

[303] 32_集成Kafka：基站数据准备

731播放

05:14

32_集成Kafka：基站数据准备

[304] 02_昨日课程内容回顾：Struc...

658播放

09:02

02_昨日课程内容回顾：StructuredStreaming 基础入门（上）

[305] 02_昨日课程内容回顾：Struc...

798播放

09:04

02_昨日课程内容回顾：StructuredStreaming 基础入门（下）

[306] 03_物联网数据实时分析：需求概述...

1079播放

05:56

03_物联网数据实时分析：需求概述及数据准备（上）

[307] 03_物联网数据实时分析：需求概述...

1057播放

05:53

03_物联网数据实时分析：需求概述及数据准备（下）

[308] 04_物联网数据实时分析：基于DS...

548播放

06:51

04_物联网数据实时分析：基于DSL实现（上）

[309] 04_物联网数据实时分析：基于DS...

1344播放

06:49

04_物联网数据实时分析：基于DSL实现（下）

[310] 05_物联网数据实时分析：基于SQ...

1443播放

08:18

05_物联网数据实时分析：基于SQL实现

[311] 06_数据去重及案例演示

1294播放

09:35

06_数据去重及案例演示

[312] 07_Continuous Pro...

654播放

10:23

07_Continuous Processing连续处理原理及演示（上）

[313] 07_Continuous Pro...

1192播放

10:30

07_Continuous Processing连续处理原理及演示（下）

[314] 08_流式处理：时间概念（上）

1425播放

05:39

08_流式处理：时间概念（上）

[315] 08_流式处理：时间概念（下）

1197播放

05:43

08_流式处理：时间概念（下）

[316] 09_event-time 窗口分...

929播放

08:39

09_event-time 窗口分析：原理剖析

[317] 10_event-time 窗口分...

1360播放

06:00

10_event-time 窗口分析：编程测试（上）

[318] 10_event-time 窗口分...

546播放

05:59

10_event-time 窗口分析：编程测试（下）

[319] 11_event-time 窗口生...

849播放

05:29

11_event-time 窗口生成（上）

[320] 11_event-time 窗口生...

1264播放

05:34

11_event-time 窗口生成（下）

[321] 12_水位Watermark引入及...

622播放

05:54

12_水位Watermark引入及延迟数据（上）

[322] 12_水位Watermark引入及...

807播放

05:57

12_水位Watermark引入及延迟数据（下）

[323] 13_水位Watermark计算及...

673播放

09:40

13_水位Watermark计算及案例讲解

[324] 14_实时综合案例：背景概述

881播放

09:36

14_实时综合案例：背景概述

[325] 15_实时综合案例：内容提纲（上）

863播放

06:07

15_实时综合案例：内容提纲（上）

[326] 15_实时综合案例：内容提纲（下）

1216播放

06:12

15_实时综合案例：内容提纲（下）

[327] 17_环境搭建说明：大数据环境

880播放

05:59

17_环境搭建说明：大数据环境

[328] 18_环境搭建说明：应用开发环境

1100播放

04:30

18_环境搭建说明：应用开发环境

[329] 19_项目初始化：加载属性文件

1381播放

09:24

19_项目初始化：加载属性文件

[330] 20_项目初始化：工具类 Spar...

958播放

06:14

20_项目初始化：工具类 SparkUtils

[331] 21_实时综合案例：模拟交易订单数...

501播放

08:17

21_实时综合案例：模拟交易订单数据

[332] 22_实时综合案例：数据实时ETL...

1419播放

08:01

22_实时综合案例：数据实时ETL（一）

[333] 23_实时综合案例：数据实时ETL...

1278播放

09:50

23_实时综合案例：数据实时ETL（二）（上）

[334] 23_实时综合案例：数据实时ETL...

611播放

09:53

23_实时综合案例：数据实时ETL（二）（下）

[335] 24_实时综合案例：数据实时ETL...

800播放

07:08

24_实时综合案例：数据实时ETL（三）（上）

[336] 24_实时综合案例：数据实时ETL...

647播放

07:14

24_实时综合案例：数据实时ETL（三）（下）

[337] 25_实时应用停止：思路分析（上）

1266播放

06:12

25_实时应用停止：思路分析（上）

[338] 25_实时应用停止：思路分析（下）

1081播放

06:09

25_实时应用停止：思路分析（下）

[339] 26_实时应用停止：编程实现及测试...

1471播放

05:16

26_实时应用停止：编程实现及测试（上）

[340] 26_实时应用停止：编程实现及测试...

709播放

05:15

26_实时应用停止：编程实现及测试（下）

[341] 27_实时增量存储：概述（HBas...

615播放

05:00

27_实时增量存储：概述（HBase及Elasticsearch）

[342] 28_存储Elasticsearc...

829播放

06:39

28_存储Elasticsearch：集成 Elasticsearch

[343] 01_上次课程内容回顾（上）

1319播放

12:42

01_上次课程内容回顾（上）

[344] 01_上次课程内容回顾（下）

1470播放

12:40

01_上次课程内容回顾（下）

[345] 02_实时应用数据源Kafka中数...

1163播放

08:29

02_实时应用数据源Kafka中数据来源

[346] 03_实时存储HBase：业务实现...

1082播放

05:11

03_实时存储HBase：业务实现概述（上）

[347] 03_实时存储HBase：业务实现...

1282播放

05:14

03_实时存储HBase：业务实现概述（下）

[348] 04_实时存储HBase：编写应用...

765播放

05:47

04_实时存储HBase：编写应用主类整体结构

[349] 05_实时存储HBase：编写st...

1238播放

09:28

05_实时存储HBase：编写streamingProcess方法整体结构

[350] 06_实时存储HBase：编写HB...

1298播放

07:43

06_实时存储HBase：编写HBaseDao 数据层（上）

[351] 06_实时存储HBase：编写HB...

1155播放

07:50

06_实时存储HBase：编写HBaseDao 数据层（下）

[352] 07_实时存储HBase：保存偏移...

1315播放

09:12

07_实时存储HBase：保存偏移量至Zookeeper（上）

[353] 07_实时存储HBase：保存偏移...

1363播放

09:12

07_实时存储HBase：保存偏移量至Zookeeper（下）

[354] 08_实时存储HBase：从Zoo...

1365播放

06:04

08_实时存储HBase：从Zookeeper加载偏移量（上）

[355] 08_实时存储HBase：从Zoo...

1002播放

06:04

08_实时存储HBase：从Zookeeper加载偏移量（下）

[356] 09_实时存储HBase：测试运行...

1443播放

06:12

09_实时存储HBase：测试运行SparkStreaming实现应用（上）

[357] 09_实时存储HBase：测试运行...

955播放

06:09

09_实时存储HBase：测试运行SparkStreaming实现应用（下）

[358] 10_实时存储HBase：基于St...

788播放

06:59

10_实时存储HBase：基于StructuredStreaming实现（上）

[359] 10_实时存储HBase：基于St...

753播放

07:02

10_实时存储HBase：基于StructuredStreaming实现（下）

[360] 11_实时订单报表：整体业务概述

801播放

06:42

11_实时订单报表：整体业务概述

[361] 12_实时订单报表：Spark-R...

1510播放

09:29

12_实时订单报表：Spark-Redis库使用（上）

[362] 12_实时订单报表：Spark-R...

1386播放

09:28

12_实时订单报表：Spark-Redis库使用（下）

[363] 13_实时订单报表：报表业务主类结...

1240播放

06:10

13_实时订单报表：报表业务主类结构编写（上）

[364] 13_实时订单报表：报表业务主类结...

852播放

06:15

13_实时订单报表：报表业务主类结构编写（下）

[365] 14_报表开发：总销售额实现和测试...

910播放

07:00

14_报表开发：总销售额实现和测试（上）

[366] 14_报表开发：总销售额实现和测试...

1266播放

07:02

14_报表开发：总销售额实现和测试（下）

[367] 15_报表开发：省份销售额实现

671播放

09:33

15_报表开发：省份销售额实现

[368] 16_报表开发：城市销售额实现（上...

591播放

05:44

16_报表开发：城市销售额实现（上）

[369] 16_报表开发：城市销售额实现（下...

626播放

05:49

16_报表开发：城市销售额实现（下）

[370] 17_报表开发：Double 精度...

552播放

06:26

17_报表开发：Double 精度丢失处理（上）

[371] 17_报表开发：Double 精度...

1436播放

06:31

17_报表开发：Double 精度丢失处理（下）

[372] 18_报表开发：每日实时统计需求说...

979播放

07:08

18_报表开发：每日实时统计需求说明

[373] 19_报表开发：每日实时统计（一）...

1002播放

07:32

19_报表开发：每日实时统计（一）（上）

[374] 19_报表开发：每日实时统计（一）...

1204播放

07:31

19_报表开发：每日实时统计（一）（下）

[375] 20_报表开发：每日实时统计（二）...

1262播放

11:06

20_报表开发：每日实时统计（二）（上）

[376] 20_报表开发：每日实时统计（二）...

894播放

11:09

20_报表开发：每日实时统计（二）（下）

[377] 21_报表开发：每日实时统计（三）...

640播放

06:05

21_报表开发：每日实时统计（三）（上）

[378] 21_报表开发：每日实时统计（三）...

1016播放

06:03

21_报表开发：每日实时统计（三）（下）

[379] 23_应用打包提交运行本地模式（一...

1321播放

06:11

23_应用打包提交运行本地模式（一）（上）

[380] 23_应用打包提交运行本地模式（一...

977播放

06:14

23_应用打包提交运行本地模式（一）（下）

[381] 24_应用打包提交运行本地模式（二...

1023播放

08:55

24_应用打包提交运行本地模式（二）

[382] 25_应用性能调优：数据本地性（上...

1417播放

05:20

25_应用性能调优：数据本地性（上）

[383] 25_应用性能调优：数据本地性（下...

1434播放

05:25

25_应用性能调优：数据本地性（下）

[384] 26_应用性能调优：SparkSt...

1076播放

08:01

26_应用性能调优：SparkStreaming反压机制

[385] 27_应用性能调优：动态资源分配

1118播放

07:59

27_应用性能调优：动态资源分配

[386] 28_应用性能调优：日志管理（上）

904播放

05:07

28_应用性能调优：日志管理（上）

[387] 28_应用性能调优：日志管理（下）

921播放

05:09

28_应用性能调优：日志管理（下）