内网网站建设流程,自己做电商网站.,深圳网站制作公司平台,如何手机做网站文章目录熟悉Python懂R语言掌握SQL大数据基础数据库常用类型多表查询更多聚合函数distinctcase when窗口函数动态更新一行变多行调优内容整理自《拿下offer 数据分析师求职面试指南》—徐粼著 第四章编程技能考查其他内容#xff1a;【数据分析师求职面试指南】必备基础知识整…
文章目录熟悉Python懂R语言掌握SQL大数据基础数据库常用类型多表查询更多聚合函数distinctcase when窗口函数动态更新一行变多行调优内容整理自《拿下offer 数据分析师求职面试指南》—徐粼著 第四章编程技能考查其他内容【数据分析师求职面试指南】必备基础知识整理【数据分析师求职面试指南】必备编程技能整理之Hive SQL必备用法【数据分析师求职面试指南】实战技能部分熟悉Python
懂R语言
掌握SQL
大数据基础
Hive时Hadoop的一个数据仓库工具将结构化的数据文件映射为一个数据库表并提供类SQL查询功能Hive SQL Hadoop主要解决两大问题大数据存储和大数据分析。解决分别依赖HDFS和Mapreduce。 HDFS可扩展的、容错的、高性能的分布式文件系统异步复制一次写入、多次读取主要负责存储。 MapReduce使分布式计算框架包含Map映射和Reduce归约过程负责在HDFS上进行计算。
Hadoop存储计算海量数据但是需要前端实时展示数据变化情况时无法保证实时性。MySQL是将数据存储在本地服务器的关系数据库可满足实时展示但可能因计算量大使任务杀死。
目前通用方法在Hadoop中通过Hive SQL 对原始数据集进行处理尽量在Hive中完成大数据量的计算之后将处理好的数据通过出仓的方式导入MySQL。
下面是以Hive SQL为例
数据库常用类型
不涉及子查询的单表查询SQL语句select,from,where,group by,having,order by select执行顺序from-where-group by -select-having-order by group by存在时select后非聚合字段都会被视为分组字段要保证一一对应group by在sellect之前所以不能直接使用别名。 只有存在group by才使用having主要针对聚合后字段及逆行筛选可以使用字段别名。 desc降序asc升序
多表查询
join:以字段列为单位连接 【使用更广泛】。 1. inner join(内连接)只保留两个表同时存在的记录 2. left join(左连接)保留左表所有记录无匹配用NULL 3. right join:保留右表所有记录 4. full join左右表记录都保留
union以记录行为单位连接需要保证连接的两表字段数量相同且按顺序一一对应。 mysql中有union.union allHive 只有union all(不去重)
Hive大多是分区表加快查询速度节省计算资源。没有索引每次查询要全量扫描增加分区可以减少每次扫描的数量。 分区表增量表和全量表。
更多
聚合函数
出现select后对记录按照分组字段进行汇总
聚合函数含义sum(col)计算分组后组内所有记录的和avg(col)…均值count(col)记录的数量stddev(col)标准差variance(col)方差max()min()最大最小值percentile(col,p)p分位数p:0~1
distinct
去重两个场景 一使select后使用对整体记录去重所有字段值相同select distinct id,name... 二是聚合函数时实现分组后去重再进行聚合计算。count(distinct subject)统计参加过考试的学科数
case when
使用在分组语句和选择语句中group by后不可使用字段别名提供新的分组字段。
select case when city in (青岛,济南)then 山东else 其他end as provincecount(1) as total
from table
where pt2019-01-01
group by case when city in (青岛,济南)then 山东else 其他endselect后基于现有字段生成新字段聚合函数中count(distinct case when score60 then subject end)as total_suc_subject统计考试通过的学科数
聚合函数distinctcase when 基本完成SQL分组计算
窗口函数
类似聚合函数也会对记录分组后进行聚合计算但不会为每组只返回一个值而是多个。准确说为分组中每条记录都返回特定值。 只能出现select后并且不会再使用group by 基本结构函数名() over (partition by col1,col2 order by col3 desc/asc,col4 asc/desc) partition by表示对所有记录按照col1,col2分组有相同的记录按照col3,col4降序或升序排列。
常用一定要掌握可以减少表与表的连接的
动态更新
用户留存率n天前使用App的用户今天依然使用的占比。指标在原始数据产生n天后获得需要对n天前分区数据进行更新涉及动态分区概念。
Hive不支持insert、update、delete无法直接修改记录通过对分区全量更新实现数据修改。
首先建分区表
一行变多行
group by 多行变一行
调优
比如当需要对大表小表进行join操作时可以使用MAPJOIN将小表加载到内存中通常小表大小营销与25MB。
若上述操作后计算速度依旧不快考虑数据倾斜问题。 执行Hive SQL语句过程中经历Map,Reduce两个步骤
