推广 热搜:   公司  企业  中国  快速    行业  上海  未来  设备 

大数据面试题(校招)

   日期:2024-12-21     移动:http://fabua.ksxb.net/mobile/quote/4352.html

一般有关系建模和维度建模,关系建模遵循范式,一般有一范式、二范式、三范式、bc范式等。
维度建模一般有星型模型、雪花模型、星座模型。星型模型允许数据冗余但是减少shuffle、雪花模型一般遵循范式,数据冗余少但增多工作量。星座模型与前两种不冲突,由多张事实表汇总。

维度建模有两种表:维度表、事实表。
事实表存储现实发生的操作型事件,每完成一次事件对应增加一次记录。维度表就是一件事件的多个维度。事实表多个外键与维度表关联。
维度建模4个过程
选择业务过程、声明粒度、确认维度、确认事实。

原因:大量空值、key分布不均。
解决
1.在map后combine
2.两次mr,第一次map对key加随机前缀,就会平均分配到reducer中,第二次mr去除前缀,性能较低
3.增加reduce个数,提升并行度
4.自定义hash,将key平均分配
5.(hive)groupby代替distinct,distinct只有一个reduce任务
6.(hive)大表join小表:开启map_join,将小表加载到内存,在map端join,否则在reduce端join
7.(hive)大表join大表:a表加随机数,b表扩容,然后ab表聚合

见上

ods层
保持数据不修改、压缩、创建分区表防止全表扫描
dwd层
去空、过滤无意义数据、将用户行为和业务表一致性处理、脱敏、压缩、列式存储
dws层
统计各个主题当天行为
dwt层
以分析的主题对象为建模驱动,基于上层的应用和产品的指标需求,构建主题对象的全量宽表,是累计的度量值
ods层
对各个指标分析

维度建模:减少关联
关系建模:完整性,准确性,减少冗余,节省存储空间

星型模型:效率高,方便查询
雪花模型:冗余小、规范

事务是一组不可再分割的操作集合

shuffle,yarn,hdfs读写流程

map方法之后,数据首先进入分区方法,标记好分区之后,数据写入环形缓冲区中,环形缓冲区100M,在缓冲区内进行分区和分区内排序,快排,写到80%时,进行反向溢写,溢写会产生大量溢写文件,多个溢写文件采用分区内归并排序,形成大的溢写文件,可自定义combiner方法进行汇总操作,写到磁盘中等待拉取。
reduce task按照自己的分区号拉取各个 MapTask 机器上相应的结果分区数据,数据存到内存中,如果不够就存到硬盘中,然后归并排序, shuffle过程结束,进入reduce方法。

最少:map快排、归并、reduce归并三次

  1. 客户端向namenode请求下载文件
  2. namenode获取第一块block的locations,同一个block有多个副本按拓扑排序(远近,离客户端最近的排在前面
  3. 客户端会按照locations排序与对应的datanode连接,向datanode请求读数据
  4. datanode向客户端传输数据
  5. 读完第一块,关闭datanode连接,重复,直到读完所有block,这些操作对客户端来说是透明的(也就是用户不需要知道下面都做了什么,客户端的角度看来只是读一个持续不断的流。
  6. 客户端组装所有block

  1. 客户端向namenode发送请求
  2. namenode检查文件路径是否存在、是否重名、权限等
  3. namenode向客户端相应可以发送
    10.客户端把文件切块,块即packet(64k,写到发送队列data queue,并询问namenode该写在哪
  4. namenode查询datenode信息,规划block存储位置
  5. namenode返回可以存储的ip列表,即pipeline管道
  6. 客户端向管道第一个发送数据,第一个向第二个发送数据,以此类推。
  7. 容错机制:还有一个确认队列ack queue,也是由packet构成,等到所有pipeline中所有的datanode都表示已经收到的时候,ack queue才会删除对应的packet。当某个datanode发生错误的时候,采用以下几步
    1. pipeline 被关闭掉
    2. 为了防止丢包 ack queue 里的 packet 会同步到 data queue 里
    3. 把产生错误的 datanode 上当前在写但未完成的 block 删掉
    1. block 剩下的部分被写到剩下的两个正常的 datanode 中
    2. namenode 找到另外的 datanode 去创建这个块的复制(也是三个的)。
      当然,这些操作对客户端来说是无感知的透明性)。
  8. 关闭写入流

map任务结束后通知MapReduceApplicationMaster,reduce定期向MRAM询问map输出与主机的对应关系。直到获得所有输出位置。

shuffle排序,按字典顺序排序的,目的是把相同的的key可以提前一步放到一起。

shuffle就是把key相同的东西放到一起去,其实不用sort(排序)也能shuffle,那为什么要sort排序呢

sort是为了通过外排(外部排序)降低内存的使用量:因为reduce阶段需要分组,将key相同的放在一起进行规约,使用了两种算法:hashmap和sort,如果在reduce阶段sort排序(内部排序),太消耗内存,而map阶段的输出是要溢写到磁盘的,在磁盘中外排可以对任意数据量分组(只要磁盘够大),所以,map端排序(shuffle阶段),是为了减轻reduce端排序的压力。

数据倾斜,小文件,优化,hql->mr,四个排序

全局排序,分组排序

sort by :reduce前

a表加随机数,b表扩容,聚合

sql->AST->query block->operator tree->优化->mr任务树->优化->提交

hiveSQL被parser(解析)成AST(抽象语法树
AST转化成query block(查询块
query block被转化成operator tree(操作树
优化operator tree
operator tree转化成mr任务
优化成最终的mr任务

mapjoin
行列过滤
列式存储
分区
设置map、reduce个数
小文件:jvm重用、combiner、marge
开启combiner
压缩
换引擎

开启combiner
jvm重用
两个mr(marge

1、数据倾斜的原因
(1)、key分布不均匀。
(2)、业务数据本身的原因。
(3)、建表考虑不周。
(4)、某些SQL本身就有数据倾斜。

2、如何避免数据的倾斜

(1)给key一个随机的值,打散key。

(2)Hive中的参数调节
①hive.map.aggr = true---------------作用Map 端部分聚合,相当于Combiner
②hive.groupby.skewindata=true
有数据倾斜的时候进行负载均衡,当选项设定为 true,生成的查询计划会有两个 MR Job。第一个 MR Job 中,Map 的输出结果集合会随机分布到 Reduce 中,每个 Reduce 做部分聚合操作,并输出结果,这样处理的结果是相同的 Group By Key 有可能被分发到不同的 Reduce 中,从而达到负载均衡的目的;第二个 MR Job 再根据预处理的数据结果按照 Group By Key 分布到 Reduce 中(这个过程可以保证相同的 Group By Key 被分布到同一个 Reduce 中,最后完成最终的聚合操作。

(3)SQL语句的调节:1、选用join key分布最均匀的表作为驱动表。2、大小表join的时候,让维度较小的表先进内存。3、大表join的时候,把空值的key变成一个字符串加上一个随机数,把倾斜的数据分到不同的reduce上。4、count distinct大量相同特殊值。

TEXTFILE,
Hive数据表的默认格式,存储方式:行存储。
可以使用Gzip压缩算法,但压缩后的文件不支持split
在反序列化过程中,必须逐个字符判断是不是分隔符和行结束符,因此反序列化开销会比SequenceFile高几十倍。
SEQUENCEFILE
压缩数据文件可以节省磁盘空间,但Hadoop中有些原生压缩文件的缺点之一就是不支持分割。支持分割的文件可以并行的有多个mapper程序处理大数据文件,大多数文件不支持可分割是因为这些文件只能从头开始读。Sequence File是可分割的文件格式,支持Hadoop的block级压缩。
Hadoop API提供的一种二进制文件,以key-value的形式序列化到文件中。存储方式:行存储。
sequencefile支持三种压缩选择:NONE,RECORD,BLOCK。Record压缩率低,RECORD是默认选项,通常BLOCK会带来较RECORD更好的压缩性能。
优势是文件和hadoop api中的MapFile是相互兼容的
RCFILE
存储方式:数据按行分块,每块按列存储。结合了行存储和列存储的优点
RCFile 保证同一行的数据位于同一节点,因此元组重构的开销很低
像列存储一样,RCFile 能够利用列维度的数据压缩,并且能跳过不必要的列读取
数据追加:RCFile不支持任意方式的数据写操作,仅提供一种追加接口,这是因为底层的 HDFS当前仅仅支持数据追加写文件尾部。
行组大小:行组变大有助于提高数据压缩的效率,但是可能会损害数据的读取性能,因为这样增加了 Lazy 解压性能的消耗。而且行组变大会占用更多的内存,这会影响并发执行的其他MR作业。 考虑到存储空间和查询效率两个方面,Facebook 选择 4MB 作为默认的行组大小,当然也允许用户自行选择参数进行配置。
ORCFILE
存储方式:数据按行分块,每块按照列存储。
压缩快,快速列存取。效率比rcfile高,是rcfile的改良版本。

一、常用日期函数

  1. unix_timestamp:返回当前或指定时间的时间戳
    select unix_timestamp();
    select unix_timestamp(“2020-10-28”,‘yyyy-MM-dd’);

  2. from_unixtime:将时间戳转为日期格式
    select from_unixtime(1603843200);

  3. current_date:当前日期
    select current_date;

  4. current_timestamp:当前的日期加时间
    select current_timestamp;

  5. to_date:抽取日期部分
    select to_date(‘2020-10-28 12:12:12’);

  6. year:获取年
    select year(‘2020-10-28 12:12:12’);

  7. month:获取月
    select month(‘2020-10-28 12:12:12’);

  8. day:获取日
    select day(‘2020-10-28 12:12:12’);

  9. hour:获取时
    select hour(‘2020-10-28 12:13:14’);

  10. minute:获取分
    select minute(‘2020-10-28 12:13:14’);

  11. second:获取秒
    select second(‘2020-10-28 12:13:14’);

  12. weekofyear:当前时间是一年中的第几周
    select weekofyear(‘2020-10-28 12:12:12’);

  13. dayofmonth:当前时间是一个月中的第几天
    select dayofmonth(‘2020-10-28 12:12:12’);

  14. months_between: 两个日期间的月份
    select months_between(‘2020-04-01’,‘2020-10-28’);

  15. add_months:日期加减月
    select add_months(‘2020-10-28’,-3);

  16. datediff:两个日期相差的天数
    select datediff(‘2020-11-04’,‘2020-10-28’);

  17. date_add:日期加天数
    select date_add(‘2020-10-28’,4);

  18. date_sub:日期减天数
    select date_sub(‘2020-10-28’,-4);

  19. last_day:日期的当月的最后一天
    select last_day(‘2020-02-30’);

  20. date_format(): 格式化日期
    select date_format(‘2020-10-28 12:12:12’,‘yyyy/MM/dd HH:mm:ss’);

二、常用取整函数
21. round: 四舍五入
select round(3.14);
select round(3.54);

  1. ceil: 向上取整
    select ceil(3.14);
    select ceil(3.54);

floor: 向下取整
23. select floor(3.14);
select floor(3.54);

三、常用字符串操作函数
24. upper: 转大写
select upper(‘low’);

  1. lower: 转小写
    select lower(‘low’);

  2. length: 长度
    select length(“atguigu”);

  3. trim: 前后去空格
    select trim(" atguigu ");

  4. lpad: 向左补齐,到指定长度
    select lpad(‘atguigu’,9,‘g’);

  5. rpad: 向右补齐,到指定长度
    select rpad(‘atguigu’,9,‘g’);

  6. regexp_replace:使用正则表达式匹配目标字符串,匹配成功后替换
    SELECT regexp_replace(‘2020/10/25’, ‘/’, ‘-’);

四、集合操作
31. size: 集合中元素的个数
select size(friends) from test3;

  1. map_keys: 返回map中的key
    select map_keys(children) from test3;

  2. map_values: 返回map中的value
    select map_values(children) from test3;

  3. array_contains: 判断array中是否包含某个元素
    select array_contains(friends,‘bingbing’) from test3;

  4. sort_array: 将array中的元素排序
    select sort_array(friends) from test3;

五、多维分析
36. grouping sets:多维分析

Array,Map,Struct

封装:属性方法私有化
继承:相同的属性方法提取出来
多态:同一个对象,在不同时刻表现出来的不同状态。

多态
(1)同一个对象,在不同时刻表现出来的不同状态。
(2)前提
A:有继承或者实现关系。
B:有方法的重写。
C:有父类(接口)的引用指向子类对象。
(3)多态中的成员使用特点
Fu fz = new Zi();
多态时,所有表现形式都是父类的表现形式
只有调用方法时,运行的是子类重写的方法
A:成员变量
编译看左边,运行看左边。
B:成员方法
编译看左边,运行看右边。
(4)多态中的转型
A:向上转型
把子类对象赋值给父类(接口)的引用
B:向下转型
把父类(接口)的引用强制转换成子类对象
(5)多态的好处及弊端
A:好处
提高了程序可维护性和可扩展性。
B:弊端
不能使用子类特有内容。
要想使用,要么向下转型,要么重新创建子类对象。
instanceof 关键字:用于引用数据类型判断
格式: 对象名 instanceof 类名
返回值: true, false
作用: 判断某个对象是否属于某种数据类型

HashMap的底层结构是Node的数组
TreeMap的底层是一个Entry,他的实现是一个红黑树,方便用来遍历和搜索。

hashmap不排序
treemap排序

HashMap可以允许一个null key和多个null value。
TreeMap不允许null key,但是可以允许多个null value。

HashMap的底层是Array,所以HashMap在添加,查找,删除等方法上面速度会非常快。TreeMap的底层是一个Tree结构,在添加和删除节点的时候会进行重排序,所以速度会比较慢。

HashMap因为要保存一个Array,所以会造成空间的浪费
TreeMap只保存要保持的节点,所以占用的空间比较小。

HashMap如果出现hash冲突的话,效率会变差,不过在java 8进行TreeNode转换之后,效率有很大的提升。

抽象类(抽象类就是为了被继承:抽象类中的抽象方法必须定义为protected或者public,因为如果我们将其定义为私有的话,就无法被子类继承(其实也不是不好继承,而是不好调用;抽象类中的抽象方法如果没有在某一个子类中实现,那这个子类也要声明为抽象类;抽象类是不可以实例化的;一个类只能继承一个抽象类
接口(为了方法而生:接口中可以有变量和方法,但是接口中的变量是被强制置为public static final 的,并且只能为该类型;接口中的方法,能且只能是public abstract方法,而且对于接口中的方法都不能有具体实现;一个列可以多继承接口

关于java面试题,请看https://www.bilibili.com/video/BV12b4y167Mb

本文地址:http://fabua.ksxb.net/quote/4352.html    海之东岸资讯 http://fabua.ksxb.net/ , 查看更多

特别提示:本信息由相关用户自行提供,真实性未证实,仅供参考。请谨慎采用,风险自负。


相关最新动态
推荐最新动态
点击排行
网站首页  |  关于我们  |  联系方式  |  使用协议  |  版权隐私  |  网站地图  |  排名推广  |  广告服务  |  积分换礼  |  网站留言  |  RSS订阅  |  违规举报  |  粤ICP备2023022329号