大数据开发面试指南x
大数据开发面试指南 大数据开发面试指南 1.Java 基础篇 语言基础 锁 多线程 • 并发容器(J.U.C)
2.Java 进阶篇 JVM NIO • RPC 3.Linux 基础 4.分布式理论篇 5.大数据框架网络通信基石——Netty 6.离线数据存储——Hadoop MapReduce HDFS • Yarn 7.OLAP 引擎 Hive 8.列式数据库 Hbase 9.分布式消息队列 Kafka 10.Spark 11.Flink 12.大数据算法 关于面试 本文旨在为大家提供一个大数据学习的基本路线,完善数据开发的技术栈,我们面试一个大数据开发的时候,哪些东西是重点考察的,不会对某一个知识点进行详细的展开,希望能当成一个学习或者复习的大纲,用以查漏补缺。
1.Java 基础篇
整个大数据开发技术栈我们从实时性的角度来看,主要包含了离线计算和实时计算两大部分,而整个大数据生态中的框架绝大部分都是用 Java 开发或者兼容了 Java
的 API 调用,那么作为基于 JVM 的第一语言 Java 就是我们绕不过去的坎,Java 语言的基础也是我们阅读源码和进行代码调优的基础。
Java 基础主要包含以下部分:
语言基础 锁 多线程 • 并发包中常用的并发容器(J.U.C)
语言基础 的面向对象 的三大特征:封装、继承和多态 • Java 语言数据类型:
内置数据类型(byte、short、int、float、double、boolean、char)
引用数据类型:在 Java 中,引用类型的变量非常类似于 C/C++ 的指针,引用类型指向一个对象,指向对象的变量是引用变量,比如对象、数组 Java 的自动类型转换,强制类型转换 String 的不可变性,虚拟机的常量池,String.intern() 的底层原理 • Java 语言中的关键字:final、 、static 、transient 、instanceof 、volatile 、synchronized 的底层原理 的底层原理 • Java 中常用的集合类的实现原理:
ArrayList/LinkedList/Vector、SynchronizedList/Vector、HashMap/HashTable/ConcurrentHashMap 互相的区别以及底层实现原理 • 动态代理的实现方式 锁 • CAS、乐观锁与悲观锁、数据库相关锁机制、分布式锁、偏向锁、轻量级锁、重量级锁、monitor 锁优化、锁消除、锁粗化、自旋锁、可重入锁、阻塞锁、死锁 原因 死锁的解决办法 • CountDownLatch、CyclicBarrier 和 Semaphore 三个类的使用和原理 多线程 并发和并行 线程与进程的区别 • 线程的实现、线程的状态、优先级、线程调度、创建线程的多种方式、守护线程 • 自己设计线程池、submit() 和 execute()、线程池原理
为什么不允许使用 Executors 创建线程池 死锁、死锁如何排查、线程安全和内存模型的关系 ThreadLocal 变量 • Executor 创建线程池的几种方式:
FixedThreadPool(int nThreads) CachedThreadPool() ingleThreadExecutor() cheduledThreadPool(int corePoolSize) – newSingleThreadExecutor() ThreadPoolExecutor 创建线程池、拒绝策略 • 线程池关闭的方式 并发容器(J.U.C )
List 接口的实现类:CopyOnWriteArrayList Set 接口的实现类:CopyOnWriteArraySet、ConcurrentSkipListSet C 包中 Map 接口的实现类:ConcurrentHashMap、ConcurrentSkipListMap • JUC 包中 Queue 接口的实现类:ConcurrentLinkedQueue、ConcurrentLinkedDeque、ArrayBlockingQueue、LinkedBlockingQueue、LinkedBlockingDeque 2.Java 进阶篇
进阶篇部分是对 Java 基础篇的补充,这部分内容是我们熟读大数据框架的源码必备的技能,也是我们在面试高级职位的时候的面试重灾区。
JVM JVM 内存结构 class 文件格式、运行时数据区:堆、栈、方法区、直接内存、运行时常量池 堆和栈区别 Java 中的对象一定在堆上分配吗? Java 内存模型 计算机内存模型、缓存一致性、MESI 协议、可见性、原子性、顺序性、happens-before、内存屏障、synchronized、volatile、final、锁 垃圾回收
GC 算法:标记清除、引用计数、复制、标记压缩、分代回收、增量式回收、GC 参数、对象存活的判定、垃圾收集器(CMS、G1、ZGC、Epsilon)
JVM 参数及调优 -Xmx、-Xmn、-Xms、Xss、-XX:SurvivorRatio、-XX:PermSize、-XX:MaxPermSize、-XX:MaxTenuringThreshold Java 对象模型 oop-klass、对象头 HotSpot 即时编译器、编译优化 虚拟机性能监控与故障处理工具 jps、jstack、jmap、jstat、jconsole、 jinfo、 jhat、javap、btrace、TProfiler、Arthas 类加载机制 classLoader、类加载过程、双亲委派(破坏双亲委派)、模块化(jboss modules、osgi、jigsaw)
NIO 用户空间以及内核空间 • Linux 网络 I/O 模型:阻塞 I/O (Blocking I/O)、非阻塞 I/O (Non-Blocking I/O)、I/O 复用(I/O Multiplexing)、信号驱动的 I/O (Signal Driven I/O)、异步 I/O 灵拷贝(ZeroCopy)
BIO 与 NIO 对比 缓冲区 Buffer 通道 Channel 反应堆 选择器 • AIO RPC RPC 的原理编程模型 常用的 RPC 框架:Thrift、Dubbo、SpringCloud 的应用场景和与消息队列的差别 • RPC 核心技术点:服务暴露、远程代理对象、通信、序列化 3.Linux 基础
了解 Linux 的常用命令 远程登录 上传下载 系统目录 文件和目录操作 Linux 下的权限体系 压缩和打包 用户和组 Shell 脚本的编写 • 管道操作 4. 分布式理论篇
中的一些基本概念:集群(Cluster)、负载均衡(Load Balancer)等 一致性、2PC 和 3PC CAP 基础:时间、时钟和事件顺序 Paxos Raft、Zab 系统理论进阶:选举、多数派和租约 锁的解决方案 事务的解决方案 • 分布式 ID 生成器解决方案 5. 大数据框架网络通信基石——Netty
Netty 是当前最流行的 NIO 框架,Netty 在互联网领域、大数据分布式计算领域、游戏行业、通信行业等获得了广泛的应用,业界著名的开源组件只要涉及到网络通信,Netty 是最佳的选择。
关于 Netty 我们要掌握:
我们要掌握:
• Netty 三层网络架构:Reactor 通信调度层、职责链 PipeLine、业务逻辑处理层 Netty 的线程调度模型 序列化方式 • 链路有效性检测
流量整形 优雅停机策略 对 SSL/TLS 的支持 源码质量极高,推荐对部分的核心代码进行阅读:
Buffer Reactor Pipeline Handler 综述 ChannelHandler LoggingHandler TimeoutHandler CodecHandler • Netty 的 MessageToByteEncoder 6. 离线数据存储——Hadoop
Hadoop 体系是我们学习大数据框架的基石,尤其是 MapReduce、HDFS、Yarn 三驾马车基本垫定了整个数据方向的发展道路。也是后面我们学习其他框架的基础,关于 Hadoop 本身我们应该掌握哪些呢? 架构理解(基础)
HDFS 源码/工作原理(高级)
架构理解(基础)
源码/原理/Shuffle 原理(高级)
MapReduce 二次排序(编程,必选)
架构理解(基础)
• YARN 源码/工作原理(高级)
MapReduce 掌握 的工作原理 能用 手写代码实现简单的 WordCount 或者 TopN 算法 掌握 MapReduce Combiner 和 Partitioner 的作用 搭建,并且能解决常见的错误 熟悉 Hadoop 集群的扩容过程和常见的坑 如何解决 MapReduce 的数据倾斜 • Shuffle 原理和减少 Shuffle 的方法
HDFS 架构图和读写流程 十分熟悉 HDFS 的配置 熟悉 DataNode 和 NameNode 的作用 NameNode 的 HA 搭建和配置,Fsimage 和 EditJournal 的作用的场景 操作文件的常用命令 • HDFS 的安全模式 Yarn 的产生背景和架构 中的角色划分和各自的作用 的配置和常用的资源调度策略 • Yarn 进行一次任务资源调度的过程 7.OLAP 引擎 Hive
Hive 是一个数据仓库基础工具,在 Hadoop 中用来处理结构化数据。它架构在 Hadoop 之上,总归为大数据,并使得查询和分析方便。Hive 是应用最广泛的 OLAP 框架。Hive SQL 也是我们进行 SQL 开发用的最多的框架。
关于 Hive 你必须掌握的知识点如下:
你必须掌握的知识点如下:
• HiveSQL 的原理:我们都知道 HiveSQL 会被翻译成 MapReduce 任务执行,那么一条 SQL 是如何翻译成 MapReduce 的? 和普通关系型数据库有什么区别? 支持哪些数据格式 在底层是如何存储 NULL 的 • HiveSQL 支持的几种排序各代表什么意思(Sort By/Order By/Cluster By/Distrbute By)
Hive 的动态分区 HQL 和 SQL 有哪些常见的区别 中的内部表和外部表的区别 表进行关联查询如何解决长尾和数据倾斜问题 • HiveSQL 的优化(系统参数调整、SQL 语句优化)
8. 列式数据库 Hbase
我们在提到列式数据库这个概念的时候,第一反应就是 Hbase。
HBase 本质上是一个数据模型,类似于谷歌的大表设计,可以提供快速随机访问海量结构化数据。它利用了 Hadoop 的文件系统(HDFS)提供的容错能力。
它是 Hadoop 的生态系统,提供对数据的随机实时读/写访问,是 Hadoop 文件系统的一部分。
我们可以直接或通过 HBase 的存储 HDFS 数据。使用 HBase 在 HDFS 读取消费/随机访问数据。
HBase 在 Hadoop 的文件系统之上,并提供了读写访问。
HBase 是一个面向列的数据库,在表中它由行排序。表模式定义只能列族,也就是键值对。一个表有多个列族以及每一个列族可以有任意数量的列。后续列的值连续地存储在磁盘上。表中的每个单元格值都具有时间戳。总之,在一个 HBase:表是行的集合、行是列族的集合、列族是列的集合、列是键值对的集合。
关于 Hbase 你需要掌握:
你需要掌握:
架构和原理 的读写流程 有没有并发问题?Hbase 如何实现自己的 MVVC 的? 中几个重要的概念:HMaster、RegionServer、WAL 机制、MemStore 在进行表设计过程中如何进行列族和 RowKey 的设计 Hbase 的数据热点问题发现和解决办法 提高 Hbase 的读写性能的通用做法 HBase 中 RowFilter 和 BloomFilter 的原理 API 中常见的比较器 预分区 的 Compaction • Hbase 集群中 HRegionServer 宕机如何解决 9. 分布式消息队列 Kafka
Kafka 是最初由 Linkedin 公司开发,是一个分布式、支持分区的(partition)、多副本的(replica)的分布式消息系统,它的最大的特性就是可以实时的处理大量数据以满足各种需求场景:比如基于 Hadoop 的批处理系统、低延迟的实时系统、Spark 流式处理引擎,Nginx 日志、访问日志,消息服务等等,用 Scala 语言编写,Linkedin 于 2010 年贡献给了 Apache 基金会并成为顶级开源项目。
Kafka 或者类似 Kafka 各个公司自己造的消息’轮子’已经是大数据领域消息中间件的事实标准。目前 Kafka 已经更新到了 2.x 版本,支持了类似 KafkaSQL 等功能,Kafka 不满足单纯的消息中间件,也正朝着平台化的方向演进。
关于 Kafka 我们需要掌握:
我们需要掌握:
的特性和使用场景 • Kafka 中的一些概念:Leader、Broker、Producer、Consumer、Topic、Group、Offset、- - Partition、ISR 的整体架构 选举策略 • fk读取和写入消息过程中都发生了什么 kf如何进行数据同步(ISR)
Kafka 实现分区消息顺序性的原理 者和消费组的关系 消费 Kafka 消息的 Best Practice(最佳实践)是怎样的 如何保证消息投递的可靠性和幂等性 Kafka 消息的事务性是如何实现的 如何管理 Kafka 消息的 Offset 的文件存储机制 Kafka 是如何支持 Exactly-once 语义的 • 通常 Kafka 还会要求和 RocketMQ 等消息中间件进行比较 10.Spark
Spark 是专门为大数据处理设计的通用计算引擎,是一个实现快速通用的集群计算平台。它是由加州大学伯克利分校 AMP 实验室开发的通用内存并行计算框架,用来构建大型的、低延迟的数据分析应用程序。它扩展了广泛使用的 MapReduce 计算模型。高效的支撑更多模式,包括交互式查询和流处理。的一个主要特点是能够在内存中进行计算,即使依赖磁盘进行复杂的运算,Spark 依然比 MapReduce 更加高效。
Spark 生态包含了:Spark Core、Spark Streaming、Spark SQL、Structured Streming 和机器学习相关的库等。
学习 Spark 我们应该掌握:
我们应该掌握:
(1 )Spark Core:
:
k 的集群搭建和集群架构(Spark 集群中的角色)
• Spark Cluster 和 Client 模式的区别
的弹性分布式数据集 RDD Spark DAG(有向无环图)
掌握 Spark RDD 编程的算子 API(Transformation 和 Action 算子)
依赖关系,什么是宽依赖和窄依赖 RDD 的血缘机制 核心的运算机制 任务调度和资源调度 CheckPoint 和容错 的通信机制 • Spark Shuffle 原理和过程 (2 )Spark Streaming:
:
原理剖析(源码级别)和运行机制 Dstream 及其 API 操作 Streaming 消费 Kafka 的两种方式 Spark 消费 Kafka 消息的 Offset 处理 数据倾斜的处理方案 Spark Streaming 的算子调优 并行度和广播变量 • Shuffle 调优 (3 )Spark SQL:
:
Spark SQL 的原理和运行机制 Catalyst 的整体架构 • Spark SQL 的 DataFrame Spark SQL 的优化策略:内存列式存储和内存缓存表、列存储压缩、逻辑查询优化、Join 的优化 (4)
)Structured Streaming Spark 从 2.3.0 版本开始支持 Structured Streaming,它是一个建立在 Spark SQL 引擎之上可扩展且容错的流处理引擎,统一了批处理和流处理。正是 Structured Streaming 的加入使得 Spark 在统一流、批处理方面能和 Flink 分庭抗礼。
我们需要掌握:
我们需要掌握:
模型 Structured Streaming 的结果输出模式 事件时间(Event-time)和延迟数据(Late Data)
• 窗口操作
水印 • 容错和数据恢复 Spark Mlib:
:
本部分是 Spark 对机器学习支持的部分,我们学有余力的同学可以了解一下 Spark 对常用的分类、回归、聚类、协同过滤、降维以及底层的优化原语等算法和工具。可以尝试自己使用 Spark Mlib 做一些简单的算法应用。
11.Flink
Apache Flink(以下简称 Flink)项目是大数据处理领域最近冉冉升起的一颗新星,其不同于其他大数据项目的诸多特性吸引了越来越多人的关注。尤其是 2019 年初 Blink 开源将 Flink 的关注度提升到了前所未有的程度。
那么关于 Flink 这个框架我们应该掌握哪些核心知识点? 这个框架我们应该掌握哪些核心知识点? 集群的搭建 架构原理 的编程模型 集群的 HA 配置 Flink DataSet 和 DataSteam API 序列化 Flink 累加器 状态 State 的管理和恢复 窗口和时间 并行度 和消息中间件 Kafka 的结合 • Flink Table 和 SQL 的原理和用法 另外这里重点讲一下,阿里巴巴 Blink 对 SQL 的支持,在阿里云官网上可以看到,Blink 部分最引以为傲的就是对 SQL 的支持,那么 SQL 中最常见的两个问题:
1.双流 JOIN • 2.State 失效问题也是我们关注的重点。
12. 大数据算法
本部分的算法包含两个部分:
第一面试中针对大数据处理的常用算法题; • 第二部分是:常用的机器学习和数据挖掘算法。
我们重点讲第一部分,第二部分我们学有余力的同学可以去接触一些,在面试的过程中也可以算是一个亮点。
常见的大数据算法问题:
常见的大数据算法问题:
1.两个超大文件找共同出现的单词 2求 TopN 3.海量数据找出不重复的数据 4.布隆过滤器 5.bit-map 6.堆 7.字典树 • 8.倒排索引 关于面试 我们先来看几个典型的 BAT 招聘大数据开发工程师的要求:
百度:
阿里:
腾讯:
以上三则招聘分别来自百度阿里和腾讯,那么我们把他们的要求分类归纳:
以上三则招聘分别来自百度阿里和腾讯,那么我们把他们的要求分类归纳:
1.1~2 门语言基础 2.扎实的后台开发基础 3.离线Hadoop/Hbase/Hive 等)
4.实时计算方向(Spark/Flink/Kafka 等)
• 5.知识面更宽优先(对口经验 + 其他)
如果你是 Apache 顶级项目的 Committer 那么恭喜你,你将会是各大公司竞相挖角对象。
我们在写简历时应该注意什么? 我们在写简历时应该注意什么? • 1.漂亮的排版,杜绝使用 word,格式化的模板,推荐使用 MarkDown 生成 PDF 2.不要堆砌技术名词,不会的不了解的不要写,否则你会被虐的体无完肤 • 3.1~2 个突出的项目经历,不要让你的简历看起来像培训班或者应届生一样浅显 • 4.写在简历上的项目我建议你要熟悉每一个细节,即使不是你开发的也要知道是如何实现的 • 5.如果有一段知名企业的实习或者工作经历那么是很大的加分 技术深度和广度? 技术深度和广度? 在技术方向,大家更喜欢一专多能,深度广度兼具的同学,当然这个要求已经很高了。但是最起码应该做到的是,你用到的技术不仅要熟悉如何使用,也应该要知晓原理。
如果你曾经作为组内的核心开发或者技术 leader 那么要突出自己的技术优势和前瞻性,不仅要熟悉使用现在已经有的轮子的优劣,也要对未来的技术发展有一定的前瞻性和预见性。
如何投递简历? 如何投递简历? 最建议的方式是直接找到招聘组的负责人或者让同学或者同事内推。