课程介绍(A000806)：
黑马程序员 大数据 Spark 分布式内存计算框架
文件目录：
| 黑马程序员 大数据 Spark 分布式内存计算框架 |
| │ ├─视频-Spark分布式内存计算框架 |
| │ │ ├─sparkday10视频 |
| │ │ │ ├─01上次课程内容回顾.mp4 47.21MB |
| │ │ │ ├─02实时应用数据源Kafka中数据来源.wmv 25.79MB |
| │ │ │ ├─03实时存储HBase：业务实现概述.wmv 26.43MB |
| │ │ │ ├─04实时存储HBase：编写应用主类整体结构.wmv 23.73MB |
| │ │ │ ├─05实时存储HBase：编写streamingProcess方法整体结构.wmv 40.07MB |
| │ │ │ ├─06实时存储HBase：编写HBaseDao 数据层.wmv 73MB |
| │ │ │ ├─07实时存储HBase：保存偏移量至Zookeeper.wmv 66.68MB |
| │ │ │ ├─08实时存储HBase：从Zookeeper加载偏移量.wmv 56.44MB |
| │ │ │ ├─09实时存储HBase：测试运行SparkStreaming实现应用.wmv 66.56MB |
| │ │ │ ├─10实时存储HBase：基于StructuredStreaming实现.wmv 78.33MB |
| │ │ │ ├─11实时订单报表：整体业务概述.wmv 19.49MB |
| │ │ │ ├─12实时订单报表：Spark-Redis库使用.wmv 73.6MB |
| │ │ │ ├─13实时订单报表：报表业务主类结构编写.wmv 60.18MB |
| │ │ │ ├─14报表开发：总销售额实现和测试.wmv 61.66MB |
| │ │ │ ├─15报表开发：省份销售额实现.wmv 42.55MB |
| │ │ │ ├─16报表开发：城市销售额实现.wmv 54.97MB |
| │ │ │ ├─17报表开发：Double 精度丢失处理.wmv 59.91MB |
| │ │ │ ├─18报表开发：每日实时统计需求说明.wmv 17.02MB |
| │ │ │ ├─19报表开发：每日实时统计（一）.wmv 82.58MB |
| │ │ │ ├─20报表开发：每日实时统计（二）.wmv 98.58MB |
| │ │ │ ├─21报表开发：每日实时统计（三）.wmv 54.96MB |
| │ │ │ ├─22流式应用调优综合概述（三个方面）.wmv 41.45MB |
| │ │ │ ├─23应用打包提交运行本地模式（一）.wmv 66.39MB |
| │ │ │ ├─24应用打包提交运行本地模式（二）.wmv 42.56MB |
| │ │ │ ├─25应用性能调优：数据本地性.wmv 37.79MB |
| │ │ │ ├─26应用性能调优：SparkStreaming反压机制.wmv 24.11MB |
| │ │ │ ├─27应用性能调优：动态资源分配.wmv 24.66MB |
| │ │ │ └─28应用性能调优：日志管理.mp4 14.58MB |
| │ │ ├─sparkday1视频 |
| │ │ │ ├─01大数据技术框架总述.mp4 31.45MB |
| │ │ │ ├─02Spark 课程说明.wmv 46.22MB |
| │ │ │ ├─03今日课程内容提纲.wmv 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 38.4MB |
| │ │ │ ├─12spark-shell运行词频统计WordCount(一）.wmv 36.12MB |
| │ │ │ ├─13spark-shell运行词频统计WordCount(二）.wmv 49.82MB |
| │ │ │ ├─14监控页面及圆周率PI运行.wmv 57.89MB |
| │ │ │ ├─15Spark Standalone集群架构.wmv 35.78MB |
| │ │ │ ├─16Spark Standalone集群部署测试（一）.wmv 84.86MB |
| │ │ │ ├─17Spark Standalone集群部署测试（二）.wmv 23.64MB |
| │ │ │ ├─18Spark Applicaiton应用组成.wmv 34.5MB |
| │ │ │ ├─19Spark 应用WEB UI监控.wmv 57.66MB |
| │ │ │ ├─20Spark Standalone HA高可用配置测试.wmv 43.42MB |
| │ │ │ ├─21Spark 应用开发：创建Maven工程及模块.wmv 30.07MB |
| │ │ │ ├─22Spark 应用开发：创建SparkContext对象.wmv 31.96MB |
| │ │ │ ├─23Spark 应用开发：词频统计Wordc编写测试.wmv 20.89MB |
| │ │ │ ├─24Spark 应用开发：词频统计TopKey（一）.wmv 14.67MB |
| │ │ │ └─25Spark 应用开发：词频统计TopKey（二）.mp4 8.86MB |
| │ │ ├─sparkday2视频 |
| │ │ │ ├─01昨日课程内容回顾（一）.mp4 24.39MB |
| │ │ │ ├─02昨日课程内容回顾（二）.wmv 38.97MB |
| │ │ │ ├─03今日课程内容提纲.wmv 29.08MB |
| │ │ │ ├─04Spark 应用提交：spark-submit命令参数.wmv 55.57MB |
| │ │ │ ├─05Spark 应用提交：提交local和Standalone模式运行.wmv 67.96MB |
| │ │ │ ├─06Spark on YARN：参数配置和服务启动.wmv 68.42MB |
| │ │ │ ├─07Spark on YARN：提交运行PI和WordCount.wmv 39.4MB |
| │ │ │ ├─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 |
| │ │ │ ├─13YARN Cluster模式运行流程及演示.wmv 55.47MB |
| │ │ │ ├─14Spark Application运行MAIN函数代码执行.wmv 30.98MB |
| │ │ │ ├─15总述Spark 应用运行.wmv 15.62MB |
| │ │ │ ├─16RDD 概念：核心抽象及RDD 论文.wmv 82.98MB |
| │ │ │ ├─17RDD 概念：RDD 定义.wmv 31.86MB |
| │ │ │ ├─18RDD 概念：RDD 特性.wmv 43.72MB |
| │ │ │ ├─19RDD 概念：WordCount中RDD.wmv 44.11MB |
| │ │ │ ├─20RDD 创建：两种方式和并行化集合.wmv 26.17MB |
| │ │ │ ├─21RDD 创建：外部存储系统和读取小文件.wmv 46.99MB |
| │ │ │ ├─22RDD 分区数目.wmv 17.43MB |
| │ │ │ └─23RDD 函数分类.mp4 16.06MB |
| │ │ ├─sparkday3视频 |
| │ │ │ ├─01昨日课程内容回顾.mp4 33.24MB |
| │ │ │ ├─02Spark 开发词频统计程序.wmv 42.05MB |
| │ │ │ ├─03今日课程内容提纲.wmv 20.82MB |
| │ │ │ ├─04分区操作函数mapPartitions和foreachPartition.wmv 39.38MB |
| │ │ │ ├─05重分区函数repartition和coalesce.wmv 30.21MB |
| │ │ │ ├─06Scala集合中聚合函数reduce和fold.wmv 21.29MB |
| │ │ │ ├─07RDD中聚合函数reduce和fold.wmv 40.44MB |
| │ │ │ ├─08RDD中聚合函数aggregate.wmv 45.93MB |
| │ │ │ ├─09PairRDDFunctions中聚合函数.wmv 51.79MB |
| │ │ │ ├─10RDD 关联函数.wmv 44.33MB |
| │ │ │ ├─11RDD 函数练习.wmv 10.44MB |
| │ │ │ ├─12RDD 持久化.wmv 49.08MB |
| │ │ │ ├─13上午课程内容回顾.wmv 46.83MB |
| │ │ │ ├─14RDD Checkpoint.wmv 48.29MB |
| │ │ │ ├─15SogouQ日志分析：数据调研和业务分析.wmv 42.18MB |
| │ │ │ ├─16SogouQ日志分析：HanLP 中文分词.wmv 42.94MB |
| │ │ │ ├─17SogouQ日志分析：读取数据封装SogouRecord.wmv 42.7MB |
| │ │ │ ├─18SogouQ日志分析：搜索关键词统计.wmv 34.93MB |
| │ │ │ ├─19SogouQ日志分析：用户搜索点击统计.wmv 27.97MB |
| │ │ │ ├─20SogouQ日志分析：搜索时间段统计.wmv 25.56MB |
| │ │ │ ├─21外部数据源：综合概述.wmv 17.05MB |
| │ │ │ ├─22外部数据源：Spark与HBase交互概述.wmv 14.92MB |
| │ │ │ ├─23外部数据源：HBase Sink.wmv 68.77MB |
| │ │ │ ├─24外部数据源：HBase Source.wmv 92.76MB |
| │ │ │ └─25外部数据源：MySQL Sink.mp4 26.51MB |
| │ │ ├─sparkday4视频 |
| │ │ │ ├─01昨日课程内容回顾.mp4 31MB |
| │ │ │ ├─02RDD 共享变量：含义及案例需求说明.wmv 69.8MB |
| │ │ │ ├─03共享变量：编程实现非单词过滤.wmv 67.64MB |
| │ │ │ ├─04Spark框架中各个模块的数据结构抽象.wmv 36.87MB |
| │ │ │ ├─05今日课程内容提纲.wmv 30.99MB |
| │ │ │ ├─06SparkSession应用入口.wmv 46.11MB |
| │ │ │ ├─07词频统计WordCount：基于DSL编程.wmv 50.18MB |
| │ │ │ ├─08词频统计WordCount：基于SQL编程.wmv 56.59MB |
| │ │ │ ├─09SparkSQL 前世今生.wmv 69.15MB |
| │ │ │ ├─10SparkSQL官方定义和特性.wmv 28.5MB |
| │ │ │ ├─11DataFrame是什么.wmv 44.61MB |
| │ │ │ ├─12DataFrame中Schema.wmv 7.68MB |
| │ │ │ ├─13DataFrame中每行数据Row.wmv 25.9MB |
| │ │ │ ├─14上午课程内容回顾.wmv 40.26MB |
| │ │ │ ├─15RDD转换DataFrame：综合概述.wmv 25.25MB |
| │ │ │ ├─16RDD转换DataFrame：反射类型推断.wmv 32.31MB |
| │ │ │ ├─17RDD转换DataFrame：自定义Schema.wmv 26.55MB |
| │ │ │ ├─18toDF函数指定列名称转换为DataFrame.wmv 31.98MB |
| │ │ │ ├─19基于DSL分析（函数说明）和SQL分析.wmv 37.45MB |
| │ │ │ ├─20电影评分数据分析：需求说明.wmv 21.26MB |
| │ │ │ ├─21电影评分数据分析：数据ETL.wmv 18.5MB |
| │ │ │ ├─22电影评分数据分析：SQL分析.wmv 23.06MB |
| │ │ │ ├─23电影评分数据分析：DSL分析.wmv 42.36MB |
| │ │ │ ├─24电影评分数据分析：保存结果至MySQL和CSV文件.wmv 39.13MB |
| │ │ │ ├─25电影评分数据分析：SparkSQL中Shuffle分区数.wmv 19.63MB |
| │ │ │ ├─26Dataset 是什么.wmv 23.62MB |
| │ │ │ ├─27RDD、DS和DF之间转换.wmv 48.84MB |
| │ │ │ ├─28面试题：如何理解RDD、DF和DS.wmv 12.84MB |
| │ │ │ ├─29外部数据源：加载load和保存save数据.wmv 41.78MB |
| │ │ │ ├─30外部数据源：案例演示.（parquet、json、csv和jdbc）.wmv 66.95MB |
| │ │ │ ├─31外部数据源：集成Hive概述.wmv 17.46MB |
| │ │ │ ├─32外部数据源：集成Hive（spark-shell）.wmv 32.62MB |
| │ │ │ ├─33外部数据源：集成Hive（IDEA开发）.wmv 24.29MB |
| │ │ │ └─34自定义UDF函数在SQL和DSL中使用.mp4 16.94MB |
| │ │ ├─sparkday5视频 |
| │ │ │ ├─01昨日课程内容回顾：核心要点.mp4 15.72MB |
| │ │ │ ├─02昨日课程内容回顾：思维导图.wmv 60.56MB |
| │ │ │ ├─03分布式SQL引擎：spark-sql交互式命令行使用.wmv 47.56MB |
| │ │ │ ├─04分布式SQL引擎：启动ThriftServer服务和beeline连接.wmv 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项目初始化：SparkSession 工具类.wmv 65.72MB |
| │ │ │ ├─15项目初始化：记录日志和配置log4j.properties文件.wmv 32.45MB |
| │ │ │ ├─16广告数据ETL：IP地址解析.wmv 48.63MB |
| │ │ │ ├─17广告数据ETL：IP 工具类.wmv 21.23MB |
| │ │ │ ├─18广告数据ETL：Hive表创建.wmv 66.44MB |
| │ │ │ ├─19广告数据ETL：日期获取.wmv 26.42MB |
| │ │ │ ├─20广告数据ETL：加载JSON数据.wmv 29.57MB |
| │ │ │ ├─21广告数据ETL：数据ETL（一）.wmv 54.01MB |
| │ │ │ ├─22广告数据ETL：数据ETL（二）.wmv 18.86MB |
| │ │ │ ├─23广告数据ETL：数据ETL（三）.wmv 33.23MB |
| │ │ │ ├─24广告数据ETL：数据ETL（四）.wmv 76.48MB |
| │ │ │ ├─25广告数据ETL：Spark 分布式缓存.wmv 27.63MB |
| │ │ │ ├─26广告数据ETL：Spark on Hive与Hive on Spark区别.wmv 17.49MB |
| │ │ │ ├─27业务报表分析：业务需求.wmv 12.53MB |
| │ │ │ ├─28业务报表分析：报表运行主类.wmv 44.81MB |
| │ │ │ ├─29业务报表分析：各地域数量分布（一）.wmv 18.79MB |
| │ │ │ ├─30业务报表分析：各地域数量分布（二）.wmv 49.37MB |
| │ │ │ ├─31业务报表分析：各地域数量分布（三）.wmv 59.29MB |
| │ │ │ ├─32业务报表分析：各地域数量分布（四）.wmv 64.78MB |
| │ │ │ ├─33广告投放的地域分布（一）.wmv 21.3MB |
| │ │ │ ├─34广告投放的地域分布（二）.wmv 35.44MB |
| │ │ │ ├─35广告投放的地域分布（三）.wmv 97.13MB |
| │ │ │ └─36广告投放的地域分布（四）.mp4 21.38MB |
| │ │ ├─sparkday6视频 |
| │ │ │ ├─01昨日课程内容回顾（一）.mp4 11.7MB |
| │ │ │ ├─02昨日课程内容回顾（二）.wmv 120.75MB |
| │ │ │ ├─03广告投放的地域分布（五）.wmv 85.99MB |
| │ │ │ ├─04广告投放其他维度分析.wmv 45.69MB |
| │ │ │ ├─05应用提交：应用开发测试概述.wmv 8.94MB |
| │ │ │ ├─06应用提交：应用打包.wmv 51.93MB |
| │ │ │ ├─07应用提交：删除分区数据和报表数据.wmv 11.77MB |
| │ │ │ ├─08集群提交运行（本地模式）.wmv 61.93MB |
| │ │ │ ├─09集群提交运行（集群模式）.wmv 69.31MB |
| │ │ │ ├─10Oozie 集成 Spark2 安装配置.wmv 46.81MB |
| │ │ │ ├─11Oozie 调度框架回顾.wmv 49.14MB |
| │ │ │ ├─12Oozie 调度 Spark2应用.wmv 139.45MB |
| │ │ │ ├─13深入剖析Oozie 组件及运行本质和配置.wmv 104.45MB |
| │ │ │ ├─14Hue 创建 Oozie 工作流.wmv 69.94MB |
| │ │ │ ├─15Oozie 调度应用：调度【ETL 应用】.wmv 56.01MB |
| │ │ │ ├─16Oozie 调度应用：调度【报表应用】.wmv 36.78MB |
| │ │ │ ├─17Hue创建Oozie WorkFlow：ETL 应用.wmv 34.6MB |
| │ │ │ ├─18Hue创建Oozie WorkFlow：报表应用.wmv 27.78MB |
| │ │ │ ├─19Hue创建Oozie Coordinator：ETL 应用.wmv 38.83MB |
| │ │ │ ├─20Hue创建Oozie Coordinator：报表应用.wmv 22.82MB |
| │ │ │ ├─21Spark 内核调度：引例WordCount.wmv 19.93MB |
| │ │ │ ├─22Spark 内核调度：RDD 依赖.wmv 29.34MB |
| │ │ │ ├─23Spark 内核调度：DAG和Stage.wmv 21.26MB |
| │ │ │ ├─24Spark 内核调度：Spark Shuffle.wmv 24.08MB |
| │ │ │ ├─25Spark 内核调度：Job 调度流程.wmv 42.06MB |
| │ │ │ ├─26Spark 内核调度：Spark 基本概念.wmv 24.28MB |
| │ │ │ ├─27Spark 并行度（一）.wmv 10.79MB |
| │ │ │ └─28Spark 并行度（一）.mp4 14.87MB |
| │ │ ├─sparkday7视频 |
| │ │ │ ├─01Spark框架中流式处理模块和四大流式计算框架.mp4 21.89MB |
| │ │ │ ├─02今日课程内容提纲.wmv 35.39MB |
| │ │ │ ├─03Straming 概述：流式应用场景.wmv 26.85MB |
| │ │ │ ├─04Straming 概述：Lambda架构.wmv 30.16MB |
| │ │ │ ├─05Straming 概述：流式数据计算模式.wmv 40.46MB |
| │ │ │ ├─06Straming 概述：SparkStreaming计算思想.wmv 32.76MB |
| │ │ │ ├─07官方案例运行：每批次词频统计WordCount.wmv 29.51MB |
| │ │ │ ├─08入门案例：Streaming编程模块.wmv 28.05MB |
| │ │ │ ├─09入门案例：代码实现及测试运行.wmv 38.87MB |
| │ │ │ ├─10入门案例：Streaming 应用监控.wmv 28.17MB |
| │ │ │ ├─11SparkStreaming 运行工作原理.wmv 68.9MB |
| │ │ │ ├─12BatchInterval和BlockInterval.wmv 24.78MB |
| │ │ │ ├─14DStream 是什么.wmv 28.75MB |
| │ │ │ ├─15DStream Operations函数概述.wmv 29MB |
| │ │ │ ├─15DStream中针对RDD操作函数说明.wmv 5.83MB |
| │ │ │ ├─16DStream中transform函数使用.wmv 23.85MB |
| │ │ │ ├─17DStream中foreachRDD函数使用.wmv 34.27MB |
| │ │ │ ├─18上午课程内容回顾.wmv 36.59MB |
| │ │ │ ├─19SparkStreaming流式应用三种状态（一）.wmv 16.5MB |
| │ │ │ ├─20SparkStreaming流式应用三种状态（二）.wmv 50.92MB |
| │ │ │ ├─21流式应用技术栈及Kafka面试题.wmv 21.32MB |
| │ │ │ ├─22SparkStreaming集成Kafka两种方式（Old和New Consumer API）.wmv 52.76MB |
| │ │ │ ├─23集成Kafk aOld Consumer API两种区别.wmv 12.76MB |
| │ │ │ ├─24Old Consumer API中Direct 方式集成：编程实现.wmv 79.18MB |
| │ │ │ ├─25Old Consumer 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应用案例：mapWithState 函数.mp4 25.56MB |
| │ │ ├─sparkday8视频 |
| │ │ │ ├─01昨日课程内容回顾：入门案例和DStream.mp4 26.7MB |
| │ │ │ ├─02昨日课程内容回顾：集成Kafka.wmv 67.52MB |
| │ │ │ ├─03昨日课程内容回顾：无状态和有状态计算.wmv 45.14MB |
| │ │ │ ├─04应用案例：实时窗口统计window.wmv 75.98MB |
| │ │ │ ├─05应用案例：实时窗口统计reduceByKeyAndWindow.wmv 66.32MB |
| │ │ │ ├─06偏移量管理：概述及Checkpoint原理.wmv 46.99MB |
| │ │ │ ├─07偏移量管理：重构代码.wmv 47.68MB |
| │ │ │ ├─08偏移量管理：Checkpoint编码实现.wmv 144.96MB |
| │ │ │ ├─09偏移量管理：手动管理偏移量和状态思路.wmv 58.46MB |
| │ │ │ ├─10偏移量管理：MySQL 存储偏移量（一）.wmv 46.31MB |
| │ │ │ ├─11偏移量管理：MySQL 存储偏移量（二）.wmv 119.84MB |
| │ │ │ ├─12偏移量管理：Kafka 自身管理（异步提交偏移量）.wmv 56.82MB |
| │ │ │ ├─13Structured Streaming结构化流模块综合概述.wmv 29.41MB |
| │ │ │ ├─14StructuredStreaming 课程内容提纲.wmv 35.03MB |
| │ │ │ ├─15Spark Streaming 不足及Structured 诞生.wmv 70.62MB |
| │ │ │ ├─16Structured Streaming 概述：模块介绍和核心思想.wmv 29.5MB |
| │ │ │ ├─17Structured Streaming 概述：编程模型.wmv 31.05MB |
| │ │ │ ├─18StructuredStreaming概述：编程模型（二）.wmv 20.07MB |
| │ │ │ ├─19入门案例WordCount：功能演示.wmv 45.57MB |
| │ │ │ ├─20入门案例WordCount：Socket数据源和Console接收器.wmv 15.83MB |
| │ │ │ ├─21入门案例WordCount：编程实现.wmv 75.48MB |
| │ │ │ ├─22Input Sources 输入源概述及File 数据源.wmv 39.17MB |
| │ │ │ ├─23Rate source数据源.wmv 19.34MB |
| │ │ │ ├─24Streaming Queries基本设置（名称、触发、检查点及输出模式）.wmv 50.92MB |
| │ │ │ ├─25输出终端Sink概述.wmv 17.44MB |
| │ │ │ ├─26输出函数foreach使用.wmv 58.01MB |
| │ │ │ ├─27输出函数foreachBatch使用.wmv 33.3MB |
| │ │ │ ├─28StructuredStreaming如何保证容错语义.wmv 26.36MB |
| │ │ │ ├─29集成Kafka概述及Kafka 消费数据.wmv 47.02MB |
| │ │ │ ├─30集成Kafka：Kafka 数据源.wmv 40.91MB |
| │ │ │ ├─31集成Kafka：实时数据ETL架构.wmv 18.92MB |
| │ │ │ ├─32集成Kafka：基站数据准备.wmv 25.91MB |
| │ │ │ └─33集成Kafka：Kafka Sink.mp4 19.15MB |
| │ │ └─sparkday9视频 |
| │ │ ├─01昨日课程内容回顾：SparkStreaming 窗口和偏移量管理.mp4 26.3MB |
| │ │ ├─02昨日课程内容回顾：StructuredStreaming 基础入门.wmv 62.5MB |
| │ │ ├─03物联网数据实时分析：需求概述及数据准备.wmv 55.84MB |
| │ │ ├─04物联网数据实时分析：基于DSL实现.wmv 69.3MB |
| │ │ ├─05物联网数据实时分析：基于SQL实现.wmv 43.17MB |
| │ │ ├─06数据去重及案例演示.wmv 49.13MB |
| │ │ ├─07Continuous Processing连续处理原理及演示.wmv 119.07MB |
| │ │ ├─08流式处理：时间概念.wmv 27.4MB |
| │ │ ├─09event-time 窗口分析：原理剖析.wmv 24.11MB |
| │ │ ├─10event-time 窗口分析：编程测试.wmv 56.77MB |
| │ │ ├─11event-time 窗口生成.wmv 51.15MB |
| │ │ ├─12水位Watermark引入及延迟数据.wmv 37.53MB |
| │ │ ├─13水位Watermark计算及案例讲解.wmv 35.8MB |
| │ │ ├─14实时综合案例：背景概述.wmv 32.2MB |
| │ │ ├─15实时综合案例：内容提纲.wmv 38.47MB |
| │ │ ├─16实时综合案例：业务需求概述.wmv 48.43MB |
| │ │ ├─17环境搭建说明：大数据环境.wmv 23.33MB |
| │ │ ├─18环境搭建说明：应用开发环境.wmv 19.93MB |
| │ │ ├─19项目初始化：加载属性文件.wmv 47.13MB |
| │ │ ├─20项目初始化：工具类 SparkUtils.wmv 34.56MB |
| │ │ ├─21实时综合案例：模拟交易订单数据.wmv 57.54MB |
| │ │ ├─22实时综合案例：数据实时ETL（一）.wmv 38.07MB |
| │ │ ├─23实时综合案例：数据实时ETL（二）.wmv 82.67MB |
| │ │ ├─24实时综合案例：数据实时ETL（三）.wmv 159.96MB |
| │ │ ├─25实时应用停止：思路分析.wmv 40.69MB |
| │ │ ├─26实时应用停止：编程实现及测试.wmv 51.67MB |
| │ │ ├─27实时增量存储：概述（HBase及Elasticsearch）.wmv 10.55MB |
| │ │ ├─28存储Elasticsearch：集成 Elasticsearch.wmv 25.69MB |
| │ │ └─29存储Elasticsearch：StructuredStreaming 实现.mp4 40.4MB |
| │ └─资料-Spark分布式内存计算框架 |
| │ ├─sparkday00虚拟机.rar 25.63GB |
| │ ├─sparkday01资料.rar 347.51MB |
| │ ├─sparkday02资料.rar 44.31MB |
| │ ├─sparkday03资料.rar 48.65MB |
| │ ├─sparkday04资料.rar 22.6MB |
| │ ├─sparkday05资料.rar 20.03MB |
| │ ├─sparkday06资料.rar 16.96MB |
| │ ├─sparkday07资料.rar 70.38MB |
| │ ├─sparkday08资料.rar 61.41MB |
| │ ├─sparkday09资料.rar 10.84MB |
| │ ├─sparkday10资料.rar 28.99MB |
| │ ├─Spark基础环境补充资料.rar 90.64MB |
| │ └─软件包.rar 15.31GB |
本站所有资源均来自网络，版权归原作者所有，本站仅提供收集与推荐，若侵犯到您的权益，请【给我们反馈】，我们将在24小时内处理！
聚资料（juziliao.com）免责声明：
1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！（gm@juziliao.com）
2. 分享目的仅供大家学习和交流，请不要用于商业用途！如需商用请联系原作者购买正版！ 3.如有链接无法下载、失效或洽谈广告，请联系网站客服（微信：shangen0228）处理！
