Spark基本知识Spark 是一种基于内存的快速、通用、可扩展的大数据分析计算引擎 。
spark与hadoop的区别Hadoop
- Hadoop 是由 java 语言编写的,在分布式服务器集群上存储海量数据并运行分布式
- 作为 Hadoop 分布式文件系统,HDFS 处于 Hadoop 生态圈的最下层,存储着所有
TheGoogleFileSystem 这篇论文,它是 GFS 的开源实现 。
- MapReduce 是一种编程模型,Hadoop 根据 Google 的 MapReduce 论文将其实现,
程序的编写变得异常简单 。综合了 HDFS 的分布式存储和 MapReduce 的分布式计
算,Hadoop 在处理海量数据时,性能横向扩展变得非常容易 。
- HBase 是对 Google 的 Bigtable 的开源实现,但又和 Bigtable 存在许多不同之处 。
【Spark基本知识】它也是 Hadoop 非常重要的组件 。
Spark
- Spark 是一种由 Scala 语言开发的快速、通用、可扩展的大数据分析引擎
- Spark Core 中提供了 Spark 最基础与最核心的功能
- Spark SQL 是 Spark 用来操作结构化数据的组件 。通过 Spark SQL,用户可以使用
- Spark Streaming 是 Spark 平台上针对实时数据进行流式计算的组件,提供了丰富的
Spark的四大特性
- Simple(易用性)Spark 提供了丰富的高级运算操作,支持丰富的算子,并支持 Java、Python、Scala、R、SQL 等语言的 API,使用户可以快速构建不同的应用 。
- Fast(速度快)Spark 将处理的每个任务都构造成一个DAG(Directed Acyclic Graph, 有向无环图)来执行,实现原理是基于RDD(Resilient Distributed Dataset, 弹性分布式数据集)在内存中对数据进行迭代计算,以实现批量和流式数据的高性能快速计算处理 。
- Spark比MR速度快的原因基于内存mapreduce任务后期再计算的时候,每一个job的输出结果会落地到磁盘,后续有其他的job需要依赖于前面job的输出结果,这个时候就需要进行大量的磁盘io操作 。性能就比较低 。spark任务后期再计算的时候,job的输出结果可以保存在内存中,后续有其他的job需要依赖于前面job的输出结果,这个时候就直接从内存中获取得到,避免了磁盘io操作,性能比较高对于spark程序和mapreduce程序都会产生shuffle阶段,在shuffle阶段中它们产生的数据都会落地到磁盘 。进程与线程mapreduce任务以进程的方式运行在yarn集群中,比如程序中有100个MapTask,一个task就需要一个进程,这些task要运行就需要开启100个进程 。spark任务以线程的方式运行在进程中,比如程序中有100个MapTask,后期一个task就对应一个线程,这里就不再是进程,这些task需要运行,这里可以极端一点:只需要开启1个进程,在这个进程中启动100个线程就可以了 。进程中可以启动很多个线程,而开启一个进程与开启一个线程需要的时间和调度代价是不一样 。开启一个进程需要的时间远远大于开启一个线程 。## Scalable(可融合性)Unified(通用性)大数据处理的传统方案需要维护多个平台,比如,离线任务是放在 Hadoop MapRedue 上运行,实时流计算任务是放在 Storm 上运行 。
- 钻石的基本知识
- 奶粉配方的基本知识
- 地球仪的基本知识
- 玉石的基本知识
- 日常检查维护基本知识是什么
- 六大茶类基本知识
- 食品安全常识基本知识
- 我国禁毒的基本知识治本之策是什么
- F1的基本知识
- 汽车操作基本知识有哪些?