黑马程序员 大数据 Spark 分布式内存计算框架

黑马程序员 大数据 Spark 分布式内存计算框架课程介绍(A000806)：

黑马程序员 大数据 Spark 分布式内存计算框架

文件目录：

黑马程序员 大数据 Spark 分布式内存计算框架

│ ├─视频-Spark分布式内存计算框架

│ │ ├─sparkday10视频

│ │ │ ├─01上次课程内容回顾.mp4 47.21MB

│ │ │ ├─02实时应用数k V $ 8 & } `据源Kafka中数据来源.wmv 25.79MB

│ │ │ ├─03实时存储HBase：业务实现概述.wmv 26.43MB

│ │ │ ├─04实时存储HBase：编写应用主类整体结构.wmv 23.73MB

│ │ │ ├─05实时存储HBase：编写streamingP` ~ z N ? : J @ zrocess方法整体结构.wmv 40.07MB

│ │ │ ├─06实时存储HBase：编写HBaseDao 数据层.wmv 73MB

│ │ │ ├─07实时存储HBase：保\ n X存偏移量至Zookeeper.wmv 66.68MB

│ │ │ ├─08实时存储HBase：从Zookeeper加载偏移量.wmv 56.44M! 7 7 7 s ] 6 MB

│ │ │ ├─09实时存储H+ J v C [ B l lBase：测试运行SparkStreaming实现应用.wmv 66.56MB

│ │ │ ├─10实时存储HBase：基于StructuredStrea= L Q g Cming实现.wmv 78.33T * RMB

│ │ │g n h e F k H { w ├─11实时订单报表：整体业务概述.wmv 19.49MB

│ │ │ ├─12实时订单报表：Spark-Redis库使用.wmv 73.6MB

│ │ │ ├─1R M ^ L3实时订单报表：报表业务主类结构编写.wmv 60.18MB

│ │ │ ├─14报表开发：总销售额实现和测试.wmv 61.66MB

│ │ │ ├─15报表开发* Z W w s {：省份销售额实现.wmv 42.55MB

│ │ │ ├─16报表开发：城市销售额实现.wmv 54.97MB

│ │ │ ├─17报表开发：Double 精度丢失处理.wmv 59.91MB

│ │ │ ├─18报表开发：每日实时统计需求说明.wmv 17.02MB

│ │ │ ├─19报表开发：每日实时统计（一）.wmv 82.58MB

│ │ │ ├─20报Q 7 | W W s 1 T表开发：每日实时i B l Y : @ E统计（二）.wmv 98.58MB

│ │ │ ├─21报表开发：每日实时统计（三）D H 7 } 0 a 1 ? ..wmv 54.96MB

│ │ │ ├─22流式应用调优综合概述（三个方面）.wmv 41.45M! j [ / i N { ) gB

│ │ │ ├─23应用打包提交运P 8 V r行本地模式（一）.wmv 66.39MB

│ │ │ ├─24应用打包提交运行本地模式（二）.wmv 42.56MB

│ │ │ ├─25应用性能调优：数据~ + w W {本地性.wmv 37.79MB

│ │ │ ├─26应用性能调优：SparkStreaming反压机制.wmv 24.11MB

│ │ │ ├─27应用性能调优：动Y f { 0 ? * 6 } !态资源分配.wmv 24.66MB

│ │ │ └─28应用性能调优：日} , A ? l志管理% n G J e.mp4 14.58MB

│ │ ├─sparkday1视频

│ │ │ ├─01大数据技术框架总述.S h c [ _mp4 31.45MB

│ │ │ ├─02Spark 课程说明.wmv 46.22MB

│ │ │ ├─T l L _ _ t g J x03今日课程内容提纲.w6 B kmv} W Q J y _ l y _ 31.95MB

│ │ │ ├─04Spark是什么.wmv 54.33MB

│ │ │ ├─05 Spark 四大特点.wmv 41.84MB

│ │ │ ├─06Spark 框架模块.wmv 53.33MB

│ │ │ ├─07Spark 运行模式.wmv 19.43MB

│ │ │ ├─08Spark 课程环境准备（虚拟机）.wmv 69.79MB

│ │ │ ├─09Spark 本地模式配置.wmv 53.15MB

│ │ │ ├─10本地模式运行spark-shell及测试.wmv 59.74MB

│ │ │ ├─11上午课程内容回顾.wmv 31 D E8.4MB

│ │ │ ├─12spark-shell运行词频统计WordCount(一）.wmvX n o v K 36.12MB

│ │ │ ├─13spark-shell运行词频统计Wordr Y D @ 5 K [ bCount(二）.wmv 49.82MB

│ │ │ ├─14监控页面及圆周率PI运行.wmv 57.89MB

│ │j s Y G X 4 o ) │ ├─15Spark St) 1 [ \ + z tandalone集群架构.wmv 35.78MB

│ │ │ ├─16Spark SB C } Mtandalone集群部署测试（一）.wmv 84.86MB

│ │ │ ├─17Spark Standalone集群部署测试（二）.wmv 23.64MB

│ │ │ ├─18Spark Applicaiton应用* \ ^ { g M : }组成.wmv 34.5MB

│ │ │ ├─19Spark 应用WEB UI监控.wmv 57.66MB

│ │ │ ├─20Spark StaE Z k Ondalone HA高可用配置测试.wmv 43.42MB

│ │ │ ├─21Spark 应用开发：创建Mavz F l Een工程及模块.wmv 30.07MB

│ │ │o M z ? ├─22Spark 应用开发：创建SF c :parkContext对象.wmv 31.96MB

│ │ │ ├─23Spark 应用开发：词频统计Wordc编写测试.wmv 20.89MB

│ │ │ ├─24SpaR h Z ! ErkQ @ ? 应用开发：词频统计TopKey（一）.wmv 14.6J C 9 j B7MB

│ │ │ └─25Spark 应用开发：^ c 8 j = w ~ b词频统计TopKey（二）.mp4 8.86MB

│ │ ├─spar# c F B q 9 T lkday2视频

│ │. l o y j p │ ├─01昨日课程内容回顾（一）.mp4 24.39MB

│ │ │ ├─02昨日课程内容回顾（二）.wmv 38.97O J 0 AMB

│ │ │ ├─03今日课程内容提纲.v b [ ^ Z X {wmv 29A G f % V.08w f J a Q l S TMB

│ │ │ ├─04Spark 应用提交：spark-submit命令参数.wmv 55.57MB

│ │ │ ├─05Spark 应用提交：提p e h交local和Standalone模式运行.wmv 67.96MB

│ │ │ ├─06So 4 B M 9 D [ h qpark on YARN：参数配置和服务启动.wmv 68.42MB

│ │ │ ├─07Spark on YARN：提交运行PI和WordCount.wmv 3k K ;9.47 : 5 N c { ^MB

│ │ │ ├─08DeployMode部署模式：client和cluster区别（理论）.wmv 17.87MB

│ │ │ ├─09DeployMode部署模式：client和cluster演示（理Standalone集群）.wmv 35.11MB

│ │ │ ├─10Spark on YARN不同DeployMode区别（画图演示）.wmv 54.21MB

│ │ │ ├─11上午内容复习回顾.wmv 32.67MB

│ │ │ ├─12YARN Client模式运行流程及演示.wmv 51.47MB

│ │ │ ├| 1 q \ a f !─13YARN ClustA z 4 $ ~ O s mer模式运行流程及演示.wmv 55.47MB

│ │ │ ├─14Spark Application运行MAIN函数代码执行.wmv 30.98MB

│ │ │ ├─15总述Spark 应U j H T用运行.wmv 15.62MB

│ │ │ ├─16RDD 概念：核心抽象及RDD 论文.wmv 82.98MB

│ │ │ ├─17RDD 概念：RDD 定义g 1 \ +.wmv 31.8$ _ ` = 8 ( k6MB

│ │ │ ├─18RDD 概念：RDD 特性.wmv 43.72MB

│ │ │ ├─19RDD 概念：WordCount中RDD.wm) x lv 44.11MB

│ │ │ ├─20RDD 创建：两种方式和并行化集合.wmv 26.17MB

│ │ │ ├─21RDD 创建：外部存储系统和读取小l p t 0 r 2 b o文件.wmv 46.99MB

│ │ │ ├─22RDD 分区数目.wmv 17.43MB

│ │ │ └o q t | t R { ]─23RDD 函数分8 D Q m N 3类.mp4 16.06MB

│ │ ├─sparkday3( 1 o m q Z视频

│ │ │ ├─01昨日课程内容回顾.mp4 33.24MB3 & 4

│ │ │ ├─02Spark 开发词频统计程序.wmv 42.05MB

│ │ │ ├─03今日课程内容提纲.wn % H 9 d ` T – 9mv 2N : 4 ; K0.82MB

│ │ │ ├─04分区操作函数mapPartitions和p a /foreachPartition.wmv 39.38MB

│ │ │ ├─05重分区函数repartition和co[ ^ T & 3ale3 V 8 0 l , )sce.wmv 30.21MB

│ │ │ ├─06Scala集合中聚合函数reduce和fold@ 6 ] [ \.wmv 21.29MB

│ │ │ ├─07RDD中聚合函数reduce和s ? } 1 # 0 #fold.wmv 40.44MB

│ │ │ ├n Q i D O R N─08RDD中聚合函数aggregate.wmB E L l E av 45.93MB

│ │ │ ├─09PairRDDFn } 9 cunctions中聚合函数.wmv 51.79MB

│ │ │ ├─10RDD 关联函H o B : 5 ~数.wm. q @ –v 44.3B 4 Q F h t x j3MB

│ │ │ ├─11RDD 函数练习.wmv 10.44MB

│ │ │ ├─12RDD 持久化V K B 7 B k e J 1.wmvu o N % K : O # s 49.08MB

│ │ │ ├─13上午课程内容回顾.wmv 46.83MB

│ │ │ ├─14RDD CheckpoiL 6 ` g 9 Int.wmv 48.29MB

│ │ │ ├─15SogouQ日志分析：数据调研和业务分析.wmv 42.18MB

│ │ │ ├─16SogouQ日志分析v t m I = J D M：HanLP 中文分词.wmv 42.94MB

│ │ │ ├─17SogouQ日志分析：读取数据封装So{ d e l 3 hgouRecord.wmv 42.7MB

│ │ │ ├─18SogouQ日志分析：搜索关键词统计.wmv 3K w ^ $ f J4.93MB

│ │ │ ├─19SogouQ日志分析：用户搜索点击统计.wmv 27.97MB

│ │ │ ├─20SogouQ日志分析：搜索时间段统计.wmv 25.56MB

│ │ │ ├─21外部数据源：综合概述.wmv 17.05MB

│ │ │ ├─22外部数据源：Spa6 v Nrk与HBase交互概述.wmv 14.92MB

│ │ │ ├─23外部数据源：HBase Sink.wmv 68.77MB

│ │ │ ├─24外部数据源：HBase Source.wmv 92.76MB

│ │ │ └─25外部数据l i D B源：MySQL Sink.mp4 26.t { s . 1 F 151MB

│ │ ├─sparkday4视频

│ │ │ ├─01昨日课程内容回顾.mp4 31MB

│ │ │ ├─02RDD 共享变量：含义及案例需求说明.wmv 69.8MB

│ │ │D i % { ├─03共享变量：编程实现非\ a I T单词过滤.wmv 67.6K q v4MB

│o 8 0 ` M r 1 │ │ ├─04Spark框架中各个模块的数据结构抽象.wmv 36.87MB

│ │ │ ├─05今日课程内容提纲.wmv 30.99MB

│ │ │ ├─06Spar– X 9 W W , ( VkSession应用入口.wmv 46.11MB

│ │ │ ├─07词频统计WordCount：基于DSL编程.wmv 50.18MB

│ │ │ ├─08词频统计WordCount：基于SQL编程.wmv 56.59MB

│ │ │ ├─09SparkSQL 前世今生.wmv 69.15MB

│ │ │ ├─10SparkSQL官方定义和特性.wmv 28.; c p ?5Md ] \B

│ │ │ ├$ @ . x s .─11D– 8 q 4 ^ ^ 7ataFrame是什r J e T么.wmv 44.61MB

│ │ │ ├─12DataFrame中Schema.wmv 7.68MB

│ │ │ ├─13DataFrame中每行数据Row.wmv 25.9MBs z \ m + 1 D 7

│ │ │ ├─14上午课程内容回顾.wmv 40.26MB

│ │ │ ├─15RDD转换DataF? H – drame：综合概述.wmv 25.25MB

│% ! n │ │ ├─16RDD转换DataFrame：反射类型推断.wmv 32.31MB

│ │ │ ├─17RDD转换DataFr9 l s ] name：自定义Schema.wmv 26.55MB

│ │ │ ├─18toDF函数指定列6 Y W Q g 4 /名称转换为DataFrame.wmv 31.98MB

│ │ │ ├─19基于[ % | L q G FDSL分析（函数说明）和SQL分析.wmK c a 1v( P ( F p | A a 37.45MB

│ │ │ ├─20电影\ p % , \评分数据分析：需求说明.wmv 21.26MB

│ │ │ ├─21电影评分数据分析：数据ETL.wmv 18.5MB

│ │ │ ├─22电影评分数据分析：SQL分析W [ 8 @ W 6 w.wmv 23.06MB

│ │ │ ├─23电影评分k h y q 8 q } – K数据分析：DSL分析.wmv 42.36MB

│ │ │ ├─24电影评分数据分析：保存结果至MySQD h t A X YL和CSV文件.wmv 39.13MB

│ │ │ ├─25电影评分数据分析：SparkSQL中Shuffl E | .le分区数.wmv 19.63MB

│ │ │ ├─26Dataset 是什么.wmv 23.62MB

│ │ │ ├─27RDD、DS和DF之间转换.wmv 48.84MB

│J } T y ) z │ │ ├─28面试题：如何理解RDD、DF和Q # # M 2 !DS.wmv 12.84MB

│ │ │ ├─29F y F d # } 7外部数据源：加载load和保存save数据.wmv 41.78MB

│ │ │ ├─30外部y ; s : + 2 2 – 1数据源：案例演示.（parquet、jC g :son、csv和jdbc）.wmv 66.95MB

│ │ │ ├─31外部数_ O / % ; F 9据源：集成Hive概述.wmv 17.46MB

│ │ │ ├─32外部数据源：集成Hive（spark-shell）.wmv 32.62MB

│ │ │ ├─33外部数据源：集成Hive（IDEA开发）.wmv 24.29MB

│ │ │ └─34自定义UDF函数在SQL和DSL中使用.mp4 16.9c ] E x4MB

│ │ ├─sparkday5视频

│ │ │ ├─01昨日课程内容回顾：核. Q 6 a % F W C l心要点.mp4 15.72MB

│ │ │ ├─02昨日课程内容回顾：思维导r \ J [ K 0图.wmv 60.56MB

│ │ │ ├─03分布式SQL引擎：spark-sql交互式命令行使用.wmv 47.56MB

│ │ │ ├─04分布式SQL引擎：启动ThriftServer服务和beeline连接.4 I * Bwmv 25.41MB

│ │ │ ├─05分布式SQL引擎：JDBC Client使用.wmv 31.04MB

│ │ │ ├─06离线数据分析流程（五步）.wmv 22.34MB

│ │ │ ├─07今日课程内容提纲.wmv 44.23MB

│ │ │ ├─08综合实战业务背景和需求概述.wmv 72.76MB

│ │ │ ├─09数据调研和业务需求.wmv 62.38MB

│ │ │ ├─10环境搭建：大数据环境.wmv 35.02MB

│ │ │ ├─11环境搭建：应用开发环境.wmv 25.72MB

│ │ │ ├─12项目初始化：属性文件和工具类.wmv 18.97MB

│ │ │ ├─13项目初始化：加载属性文件.wmv 34.86MB

│ │ │ ├─14项目初始化：J r bSparkSession 工具类.wmv 65.72MB

│ │ │ ├─15项目初始化：记录日志] X 8 ^ O K z和配置log4j.properties文件.wmv 32, ! 1 f B | R n.45MB

│ │ │ ├─1G + B T6广告数据ETL：IP地址解析.wmv 48.63MB

│ │ │ ├─1f ` % g7广告数据ETL：IP 工具类.wmv 21.23MB

│ │ │ ├─1a @ ) ~8广告数据ETL：Hive表创建.wmv 66.44MB

│ │ │ ├─19广告数据` ^ 9 2 / S 3 2ETL：日期获取.wmv 26.42MB

│ │ │ ├─20广告数据ETL：加载JSON数据.wmv 29.57MB

│ │ │ ├─21广告数据ETL：数据ETL（一）.wmv 54.01MB

│ │ │ ├─22广告数据ETL：数据ETL（t 6 ) V ,二）.wmv 18.86MB

│ │ │ ├─23x $ –广告数据ETL：数据ETL% . O & ; / y（三）.wmv 33.23MB

│ │ │ ├─24广告数据ETL：| H k 3 E m i Y %数据ETL（四）.wmv 76.48MB

│ │x s h M M v n │ ├─25广告数据ETL：Spark 分布式缓存.wmv 27.63MB

│ │ │ ├─26广告数据ETL：Spark on Hive与Hive on Spark区别.wmv 17.49MB

│ │ │ ├─27业务报表分析：O e [ ( s w业务需求.wmv 12.53MB

│ │ │ ├─28业务报表分2 j I K析：报表运行主类.w1 T l ! R \ { & [mv 44.81MB

│ │ │ ├─29业务报表分析：各地域数量分布（一）.wmv 18.79MB

│ │ │ ├─30业务报表分析：各地域数量分布（二）5 X 2.wmv 49.37MB

│ │ │ ├─31业务报表分析：各地域数量分布（三）.wmv 59.29MB

│ │ │ ├─32业务报表分析：各地域数量分布（四）.wmv 6` i P x4.78MB

│ │ │ ├─33广告投放的地域分布（一）.wmv 21.3MB

│ │ │ ├─34广告投放的地域分布（二）.wmf R ( # 4 ^ wv 35.44MB

│ │ │ ├─35广告投放的地域分布（三）.wmv 97.13MB

│ │ │ └─36广告投放的地域分布（四1 G Z O ^）.mp4 21.38MB

│ │ ├─sparkday6视频

│ │ │ ├─01昨日课程内容回顾（一）.mp4 11.7MB

│ │ │ ├─02昨日课程内容回顾（二）.wm% . G O iv 120.75MB

│ │ │ ├─G D w t 3 t x03广告投放的地域分布（五）.wmv 85.99MB

│ │ │ ├─04广告; q 6 B – C {投放其他维度分析.wmv 45.69MB

│ │ │ ├─05应用提交：应用开发测试概述.wmv 8.94MBi T . ?

│ │ │ ├─06应用提交：o d +应用打包.wmv 51.93MB

│ │ │Y j z % 0 ├─07应用提交：( h u A删除分区数据和报表数据.wmv 11.77MB

│ │ │ ├─08集群提交运行（本地模式）.wmv 61.93MB

│ │ │ ├─09集群提交运行（集群模式）.wmv 69.31MB

│ │ │ ├─10OozE h F x U S N 1 @ie 集成 Spark2 安装配置.wmv 46.81MB

│ │ │ ├─11Oozie 调度框架回顾.wmv 49.14MB

│ │ │ ├─12Oozie 调度 Spark2应用.wmv 139.45MB

│ │ │ ├─13深入剖析Oozie 组件及运行本质和配置.wmv 104.45MB

│ │ │ ├─14U C 4 } 2 } @ Y 2Hue 创建 Oozie 工作流.wmv 69.94MB

│ │ │ ├─15Oozie 调度应用：调度【ET| Y * ~ ! C E }L 应用】.wmv 56I h `.01MB

│ │ │ ├─16Ooz$ w * 8 e pie 调度应用：调度【报表应用】.wmv 36.78MB

│ │ │ ├─17Hue创建Oozie WorkFlow：ETL 应用.wmg 9 v b Y \v 34.6MB

│ │ │ ├─18Hue创建Oozie WorkFlow：报表应用.wmv 27.78MB

│ │ │ ├─A D t x D 1 p19Hue创建Oozie Coordinator：ETL 应用.wmv 38.83MB

│ │ │ ├─20Hue创建Oozie Coordinator：报表应用.M z l q @ Q M 0 {wmv 22.82MB

│ │ │ ├─21Spark 内核调度：引例WordCount.wmv; [ ! 19.93MB

│ │ │ ├─22Spark 内核调度：RDD 依赖.wmv 29.34MB

│ │ │ ├─23Spar] 0 A d Hk 内核调度：DAG和Stage.w6 J ^ . emv 21.26MB

│ │ │ ├─24Spark 内核调度：Spark Shuffle.wmv 24.08MB

│{ [ ^ W F │ │ ├─u 0 L q *2% a k5Spa/ ^ e F ? x | Irk 内核调度：Job 调度流程.wmv 42.06MB

│ │ │ ├─26Spark 内核调F \ D , F x度：Spark 基本概念.wmv 24.28MB

│ │ │ ├─27Spark 并行度（一）.wmv 10.79MB

│ │ │ └─28Spark 并行度（一）.mp4 14.87MB

│ │ ├─sparkday7视频

│ │ │D ! 1 ( Z A } t ~ ├─01Spark框架中流式处理模块和四大流式计算框架.mp4 21.89MB

│ │ │ ├─02今日课程内容提纲.wmv 35.39[ = R / j p 0 R hMB

│ │ │ ├─03Straming 概述：流式应用场景.wmv 26.85MB

│ │ │ ├─04Straming 概述：Lambda架构.wmv 30.16MB

│ │ │ ├─05Strami? 8 8 4 * Lng 概述：流式数据计算模式.wmv 40.46MB

│ │ │ ├─06Straming 概述：SparkStreaming计算思想.wmv 32.762 K a ~MB

│ │ │ ├─07官方案例运行：每批次词频统计WordCount.wmv 29.51MB

│ │ │ ├─08入A ) X a v门案例：Streaming编[ r o 2 N ~程模块.wmv 28.05MB

│ │ │ ├─09入门案例：代码实现及测试运行.wmv 38.87MB

│ │ │ ├─10入门案H R \ j V w & I [例：Streaming 应用监控.wmv 28.17MB

│ │ │ ├─11SparkSG 6 m k G . _ Ktreaming 运行工作原理.wmv 68.9MB

│ │ │ ├─12BatchInterval和BlockInterval.wmv 24.78MB

│ │ │ ├─14DStream 是什么.wmv 28.75MB

│ │ │ ├─15DStream Operations函数概述.wmv 29MB

│ │ │ ├─15DStream中针对RDD操作函数说明.wmv 5.83MB

│ │ │ ├─16DStreH A J 0am中transform函数使用.wmv 23.85MB

│ │ │ ├─17DStream中foreachRDD函数使用.wmv 34.27MB

│ │ │ ├─18上午课程内容回顾.wmv 36.59MB

│ │ │ ├─19SparkStreaming流式P Q } h X _应用三种状态（一）.wmv 16.5MB

│ │ │ ├─20SparkSt5 L U LreamiM p . ) 8 ! x T ^ng流式应用三种状态（二）.wmv 50.92MB

│ │ │ ├─2v f G q1流式应用技术栈及Kafka面试题.wmv 21.32MB

│ │ │ ├─22Spar\ X . { + ,kStreaming集成Kafka两种方式（Old和New Consumer API）.wmv 52.76MB

│ │ │ ├─23集成Kafk aOld Consumer API两种区别.wmv 12.76MB

│ │ │ ├─24Old Consumer API% Q w中Direct 方式集成：编程实现.wmv 79.18MB

│ │ │ ├─25Old Conm d [ +sumer API中Direct 方式集成：底层原理及最大数据量.wmv 31.09MB

│ │ │ ├─26New Consumer API方式集成编程.wmv 56.6MB

│ │ │ ├─27集成Kafka时获取消费偏移量信息.wmv 72.6MB

│ │ │ ├─28应用案例：业务场景和需求说明.wmv 25.56MB

│ │ │ ├─29应用案例：初始化环境.wmv 107.9MB

│ │ │ ├─30应用案例：StreamingContextUtils 工具类.wmv 24.12MB

│ │ │ ├─31应用案例：实时数据ETL存储.wmv 99.94MB

│ │ │ ├─32应用案例：updateStateByKey 函数.wmv 112.2MB

│ │ │ └─33应用k { 9案例：mapWithState 函k r q V数.mp4 25.56MB

│ │ ├─sparkday8视频

│ │ │ ├─01昨日课程内容回顾：入门案例和DStream.mp4 26.7MB

│ │ │ ├─02昨日课程内容回顾：集成Kafka.wmv 67.52MB

│ │ │ ├─03昨日课程内容回顾：无状态和有状态计( p e N g g p算.wmv 45.14MB

│ │ │ ├─04应用案例：实时窗口统计win= I ? V 1 – % \ –doR g y o uw.wmv 75.98MO Y ` _B

│ │ │ ├─05应用案例：实时窗口统计reduceByKeyAndWindow.wmv 66.32MB

│ │ │ ├─06偏移量管理：概述及Checkpoint原理.wmv 46.99MB

│ │ │ ├─07偏移量管理：重构代码.wmv 47.68MB

│ │ │ ├─08偏移量管理q \ B O : w v h A：Checkpoint编码实现.E h 0 } b rwmv 144.96MB

│ │ │ ├─09偏移量管理：手动管理偏移量和状态思路.w% ~ 7 !mv 58.6 L G X ! C46MB

│ │ │ ├─10偏移量管理：MySQL 存储偏移量（一）.wmv 46.# 6 ~ 531MB

│ │ │ ├─11偏移量管理：MySQ\ $ y i * .L 存储偏移量（二）.wmv 119.84MB

│ │ │ ├─12偏移量管理：Kafka 自身管理（异步提交Q B h A \ 9 { p &偏移量）.wmv 56.82MB

│ │ │ ├─13Structured Streaming结构化流模块综合概述.wmv 29.41MB

│8 i W c │ │ ├─14Structu* Y Z 9 * S T h BredStreaming 课程内容提纲.wmv 35_ . O N P # p.03MB

│ │ │ ├─15Spark Streaming 不足及Structured 诞生.wmv 70.62MB

│ │ │ ├─16Structured Streaming 概述：模块介绍和核心思想.wmv 29.5MB

│ │ │ ├─17Structp U ( {ured Streaming 概述：% Q r P ~编程模型.wmv 31.05MB

│ │ │ ├─18StructuredStreaming概述：编程模型（二）.wmv 20.07MB

│ │ │ ├─19入门案例WordCount：功能演示.wmv 45.5Z * E7MB

│ │ │ ├─20入门案例WordCount：Socket数据源和Console接收器.wmv 15.83MB

│ │ │ ├─21入门案例WordCount：编程实现.wmv 75N c D o M.48MB

│ │ │ ├─22Input SouM ! Frces 输入源概述及File 数据源.wmv 39.17MB

│ │ │ ├─23Rate source数据源.wmv 19.34MB

│ │ │ ├─24Streaming Queries基本设置（名称、触发、检查点及输出模式）.wmv 50.92MB

│ │ │ ├─25输出终端Sink0 b * 2 \ 0概述.wmv 17.44MB

│ │ │ ├─26输出函数foreach使用.wmv 58.01MB

│ │ │ ├─27输出函数foz t Z greachBatch使% ; p Q用.wmv 33.3MB

│ │ │ ├─28StructuredStreaming如何p C \ K = $保证容错语义.wmv 26.36MB

│ │ │ ├─29集成Kafka概述及Kafka 消费数据.wmv 47.02MB

│ │ │ ├─30集成Kafka：Kafka 数\ { * l W据源.w5 , Fmv 40.91MB

│ │ │ ├─31集成Kafka：实时数据ETL架构.wmv 18.92MB

│ │ │ ├─32! z ? x r q L集成Kafka：基, % V Z站数据准备.wmv 25.91MB

│ │ │ └─33集成Kafka：K& u M $afka Sink.mp4 19.15MB

│ │ └─sparkday9视频

│ │ ├─01昨日课程内容回顾：SparkStreaming 窗口T ] h { q O p和偏移量管理.mp4 26.3X w q ; c R eMB

│ │ ├─02昨日课程内容回顾：StructuredStreaming 基础入门.wmv 62.5MB

│ │ ├─03物联网数据实时分析：需求概述及数据准备.wmv 55.84MB

│ │ ├` Z J R V─04物联网数据实时分析：基于DSL实现.wmv 69.3MB

│ │ ├─05物联网数据实时分析：基于SQL实现.wmv 43.17MC b 8 T 1 ? nB

│ │ ├─06数据去0 A c m 6 , N K重及案例演示.wmv 49.13MB

│ │ ├─07Continuous Pr% N Q ] \ocessing连续处理原E ; J Z # .理及演示.wmv 119y # o o P , 8.07MB

│ │ ├─08流式处理：时间概念.wm\ f .v 27.4MB

│ │ ├─09event-time 窗口分析：原理剖析.wmv 24.11M# ] l ~ p OB

│ │ ├─10event-time 窗口分析：编程测试.wmv 56.77Ml H ) 4 g D 3B

│ │ ├─11event-time 窗口生成.wmv 51.15MB

│ │ ├─12水位Waterm4 S _ 3 Cark引入及延迟数据.wmv 37.53M_ ^ {B

│ │ ├─13水位Watermark计算及案例讲解.wmv 35.8MB

│ │ ├─14实时综合案例：背景概述.wmv 32.2Mn y ~ z k , : J –B

│ │ ├─15实时综合案例：内容提纲.wmv 38.47MB

│ │ ├─16实时综合案例：业务需求概述.wmv 48.43MB

│ │ ├─17环境搭建说明：大数据环境.wmv 23.33MB

│ │ ├─18环境J / l h e Z搭建说明：应用开发环境.wmv 19.93MB

│ │ ├─19项目初始化：加载属性文件= 8 =.wmv 47.13MB

│ │ ├─20项目初始化：工具类 SparkUtils.wy * 0mv 34.56MB

│ │ ├─21实时综合案例：模拟交易订单数据.wmv 57.54MB

│ │ ├─22实时综合案例：数据实时ETL（一）.wmv 38.07MB

│ │ ├─23实时k D | u }综合案例：数据实时ETL（二）.wmv 82.67MB

│ │ ├─24实时综合案例：数据实时ETL（三）.wmv 159.96MB

│ │ ├─25实时应用停止：思路分析.wmv 40.69MB

│ │ ├─2l * 9 c \ a f 66实时应用停止：编程实现及测试.wmv 51.67MB

│ │ ├─27实时增量存储：概述（HBase及Elasticsearch）.wmv 10.55MB

│ │ ├─28存储Elasticsearch：Y / M + D ~集成 Elasticsearch.wmv 25.69MB

│ │ └─29存储Elas= ( j & 4 k B rticsea: c z Z M f qrch：StructuredStreaming 实现.` Z ) _ v Pmp4 40.4ME s : o X qB

│ └─资料-Spar0 O Wk分布式内存计算框架

│ ├─sparkday00虚拟机.rar 25.63GB

│ ├─sparkday01资料.rar 347.R J o ! N 8 t S _51MB

│ ├─d : r j e D R 6sparkday02资料.rar 44.31MB

│ ├─sparkday03资料.rar 48.65MB

│ ├─sparkday04资料.rar 22.6MB

│ ├f y . Z 2 u { T─sparkday05资料.rar 20.03MB

│ ├─sparkday06资料.rar 16.96MB

│ ├─sparkday07资料.rar 70.38MB

│ ├─sparkday08资料.rar 61.41MB

│ ├─sparkday09资料g 5 H.raD y U Wr 10.8H $ % 24MB

│ ├─sparkday10资料.rar 28.99MB

│ ├─Spark基z d N \础环境补充资料@ p _.rar 90.64MB

│ └─软件包.rar 15.31GB