Spark大数据分析实战
2016-12-17 10:24:01 68 举报AI智能生成
推荐系统
作者其他创作
大纲/内容
微博情感分析
系统架构
Spark Streaming 微博收集与分析模块
实时聚类和热点分析
Cassandra持久化存储模块
Spark分析模块
情感分析
Mysql结果存储模块
提供可视化数据
数据收集
微博数据收集
数据预处理和Cassandra存储
作为存储引擎进行数据分析
热点微博分析
Spark Stream 滑动窗口API
在线情感分析
使用递归神经网路RNN经行
Spark SQL进行离线分析
微博可视化
热点新闻分析系统
新闻抓取模块
Scrapy抓取
Kafka传输
Mongo存储
实时新闻分析模块
Spark Streaming实时处理
离线新闻分析模块
可视化呈现界面
爬虫抓取网络信息
新闻文本数据预处理
新闻聚类
文本聚类分析
1. 使用向量空间模型进行数据转换
2. 通过K-Means进行聚类
数据准换为向量
向量空间模型
Spark Elastic Search 构建全文检索引擎
个性化推荐
算法
协同过滤推荐算法
基于用户的推荐
基于项目的推荐
基于模型的推荐
基于关联规则的推荐
基于效用的推荐
基于知识的推荐
组合推荐
社交网络分析
社团挖掘
聚类分析
K均值算法(K-Means)
找到社交网络中的团体
链路分析
好友关系推荐
1. 可能认识的人
\u00A02. 可能感兴趣的人
大规模新闻主题分析
主题模型LDA
可以将文档的主题以概率的形式给出
Spark大数据分析
Spark简介
Spark执行特点
中间结果无需输出到HDFS
数据格式和内存布局使用RDD
执行策略不同Stage需要shuffle
Spark优势
打造全栈多计算凡是的高效数据流水线
轻量级快速处理
Scala简化了代码
利用了第三方组件
自带80多个算子
ExternalDataSource多数据支持
社区活跃度高
Spark生态系统BDAS
数据分析栈
组件
Spark
Spark SQL
Spark Streaming
流式计算吞吐量超过Strom
GraphX
经行大规模同步全局的图计算
MLlib
分布式机器学习算法库
Spark架构
Spark组件
Dirver
创建SparkContext的main函数
Client
用户提交作业的客户端
Worker
Executor
运行Worker的Task执行器
SparkConext
RDD
DAG schedule
Task Scheduler
Task分发给Executor执行
SparkEnv
线程级别的上下文
运行逻辑
作业提交
Client->Master-> Worker->Driver->Master->RDD->Stage DAG -> TaskScheduler-> Executor
作业执行
Shuffle
弹性分布式数据集
RDD创建方式
1. HDFS输入创建
2. 父RDD转换
3. paralleize或makeRDD将单机数据创建为分布式RDD
RDD的两种操作算子
转换(Transformation)
延迟计算
行动(Action)
触发提交作业Job
RDD的重要内部属性
分区列表
计算每个分片的函数
对父RDD的依赖列表
每个数据分区的地址列表
Spark计算工作流
BDAS
SQL on Spark(替代Hive)
1. Catalyst架构及执行流程
2. SparkSql优化策略
Spark Streaming(替代Storm)
优势与特点
1. 多范式数据分析管道
3. 容错性
4. 吞吐量大(超过Storm)
Spark Stream架构
GraphX(替代GraphLab)
MLlib(替代Mahout)
Lamda架构日志分析流水线
日志分析指标
PV
UV
PVUV
漏斗模型与转化率
留存率
Lamda架构
速度层(Speed Layer)
批处理层(Batch Layer)
服务层(Serving Layer)
实时日志分析流水线架构
数据采集
Flume NG
数据汇总和转发
Flume 汇总到Kafka
数据处理
结果呈现
Flask
离线日志分析流水线架构
数据存储
Flume转储到HDFS
基于云平台和用户日志的推荐系统
数据收集聚合
结果输出
离线训练
Spark MLlib中的ALS模型
分布式的搜索引擎
计算网页的PageRank值
收藏
收藏
0 条评论
回复 删除
下一页
