RDD简介 RDD,全称为Resilient Distributed Datasets(弹性分布式数据集),是一个容错的、并行的数据结构,可以让用户显式地将数据存储到磁盘和内存中,并能控制数据的分区。...RDD混合了这四种模型,使得Spark可以应用于各种大数据处理场景。 定义: 只读的,可分区的分布式数据集;数据集可全部或部分缓存在内存中,在一个App多次计算间重用, RDD是Spark的核心。...n份,每份数据对应到RDD中的一个Partition,Partition的数量决定了task的数量,影响着程序的并行度,所以理解Partition是了解spark背后运行原理的第一步。...1000,5) 可通过算子来进行修改分区数.repartition(3) 如果使用的是scala集合的话,在特定的格式下,会根据数量量来创建分区makeRdd 读取HDFS上的数据时根据块的数量来划分分区数 Spark...在Spark中有两类task,一类是shuffleMapTask,一类是resultTask,第一类task的输出是shuffle所需数据,第二类task的输出是result,stage的划分也以此为依据
RDD在逻辑上是一个数据集,在物理上则可以分块分布在不同的机器上并发运行。RDD允许用户在执行多个查询时显示的将工作缓存在内存中,后续的查询能够重用工作集,这极大的提升了查询速度。...RDD是Spark的核心,也是整个Spark的架构基础。...image.png 文件系统中加载 SparkContext通过textFile()读取数据生成内存中的RDD 支持的数据类型: 本地文件系统(file://) 分布式文件系统HDFS加载数据(hdfs...image.png Spark采用惰性计算模式,RDD只有第一次在一个行动操作中得到时,才会真正计算,spark可以优化整个计算过程,默认情况下,spark的RDD会在每次他们进行行动操作是重新计算。...如果需要多个行动中重用一个RDD,可以使用RDD.persist()让Spark把这个RDD缓存下来。 ? image.png ?
弹性分布式数据集(RDD)不仅仅是一组不可变的JVM(Java虚拟机) 对象的分布集,可以让你执行高速运算,而且是Apark Spark的核心。 顾名思义,该数据集是分布式的。...另外,RDD将跟踪(记入日志)应用于每个块的所有转换,以加快计算速度,并在发生错误和部分数据丢失时提供回退。在这种情况下,RDD可以重新计算数据。...RDD并行操作 Spark工作原理的最大优势是:每个转化并行执行,从而大大提高速度。 数据集转化通常是惰性的,这就意味着任何转换仅在调用数据集上的操作才执行,这有助于Spark优化执行。
今天是spark专题第二篇文章,我们来看spark非常重要的一个概念——RDD。 在上一讲当中我们在本地安装好了spark,虽然我们只有local一个集群,但是仍然不妨碍我们进行实验。...spark最大的特点就是无论集群的资源如何,进行计算的代码都是一样的,spark会自动为我们做分布式调度工作。 RDD概念 介绍spark离不开RDD,RDD是其中很重要的一个部分。...创建RDD spark中提供了两种方式来创建RDD,一种是读取外部的数据集,另一种是将一个已经存储在内存当中的集合进行并行化。...') 一般来说,除了本地调试我们很少会用parallelize进行创建RDD,因为这需要我们先把数据读取在内存。...由于内存的限制,使得我们很难将spark的能力发挥出来。
[图片摘自[Spark 官网](http://spark.apache.org/)] RDD 全称 Resilient Distributed Datasets,是 Spark 中的抽象数据结构类型,...任何数据在Spark中都被表示为RDD。...简单的理解就是 RDD 就是一个数据结构,不过这个数据结构中的数据是分布式存储的,Spark 中封装了对 RDD 的各种操作,可以让用户显式地将数据存储到磁盘和内存中,并能控制数据的分区。...RDD 特性 RDD 是 Spark 的核心,也是整个 Spark 的架构基础。...它的特性可以总结如下: 它是不变的数据结构存储 它是支持跨集群的分布式数据结构 可以根据数据记录的key对结构进行分区 提供了粗粒度的操作,且这些操作都支持分区 它将数据存储在内存中,从而提供了低延迟性
RDD是一个很抽象的概念,不易于理解,但是要想学好Spark,必须要掌握RDD,熟悉它的编程模型,这是学习Spark其他组件的基础。...简单而言就是它会记录哪些RDD是怎么产生的、怎么“丢失”的等,然后Spark会根据lineage记录的信息,恢复丢失的数据子集,这也是保证Spark RDD弹性的关键点之一 Spark缓存和checkpoint...缓存(cache/persist) cache和persist其实是RDD的两个API,并且cache底层调用的就是persist,区别之一就在于cache不能显示指定缓存方式,只能缓存在内存中...,但是persist可以通过指定缓存方式,比如显示指定缓存在内存中、内存和磁盘并且序列化等。...(根据父RDD计算出子RDD) 3.RDD的依赖列表 4.RDD默认是存储于内存,但当内存不足时,会spill到disk(可通过设置StorageLevel来控制) 5.默认hash分区,可自定义分区器
RDD的Transformation,会生成一个新的RDD. 1之前已经有过介绍,见提交第一个Spark统计文件单词数程序,配合hadoop hdfs 2 Spark context Web UI available...Spark session available as 'spark'....= sc.parallelize(arr) //将集合转成RDD rdd: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[0] at...rdd3 = rdd1.cartesian(rdd2) //求笛卡尔积 rdd3: org.apache.spark.rdd.RDD[(String, String)] = CartesianRDD...16核,1G内存来启动本次计算,值得注意的是这里并不是分区越大越好,分区较大,也只有16个线程同时工作,其他线程等待,而切换线程会浪费时间。
RDD是一个很抽象的概念,不易于理解,但是要想学好Spark,必须要掌握RDD,熟悉它的编程模型,这是学习Spark其他组件的基础。...简单而言就是它会记录哪些RDD是怎么产生的、怎么“丢失”的等,然后Spark会根据lineage记录的信息,恢复丢失的数据子集,这也是保证Spark RDD弹性的关键点之一 Spark缓存和checkpoint...缓存(cache/persist) cache和persist其实是RDD的两个API,并且cache底层调用的就是persist,区别之一就在于cache不能显示指定缓存方式,只能缓存在内存中,...但是persist可以通过指定缓存方式,比如显示指定缓存在内存中、内存和磁盘并且序列化等。...(根据父RDD计算出子RDD) 3.RDD的依赖列表 4.RDD默认是存储于内存,但当内存不足时,会spill到disk(可通过设置StorageLevel来控制) 5.默认hash分区,可自定义分区器
当对一个RDD的某个分区进行操作而无法精确知道依赖前一个RDD的哪个分区时,依赖关系变成了依赖前一个RDD的所有分区。...比如,几乎所有类型的RDD操作,都涉及按key对RDD成员进行重组,将具有相同key但分布在不同节点上的成员聚合到一个节点上,以便对它们的value进行操作。...在进行reduce操作之前,单词“Spark”可能分布在不同的机器节点上,此时需要先把它们汇聚到一个节点上,这个汇聚的过程就是Shuffle,下图所示。 ...Shuffle操作 Shuffle是一个非常消耗资源的操作,除了会涉及大量网络IO操作并使用大量内存外,还会在磁盘上生成大量临时文件,以避免R错误恢复时重新计算。...Shuffle使用的本地磁盘目录由spark.local.dir属性项指定。
collect()以数组的形式返回rdd的结果,但列表中每个数乘以2 val conf = new SparkConf().setAppName("spark").setMaster("local...new SparkConf().setAppName("spark").setMaster("local") val sc = new SparkContext(conf) val rdd1...("spark").setMaster("local") val sc = new SparkContext(conf) val rdd1 = sc.parallelize(List(1,3,4...val list = List("Spark", "Hadoop", "Hive") val rdd = sc.parallelize(list) println(rdd.count...()) println(rdd.collect().mkString(",")) persist() persist(MEMORY_ONLY) 表示将RDD作为反序列化的对象存储在JVM中,如果内存不足
用户还可以要求 Spark 将 RDD 持久化到内存中,以便在并行操作中有效地重用它。 最后,RDD 会自动从节点故障中恢复。 Spark 中的第二个抽象是可以在并行操作中使用的共享变量。...Spark 支持两种类型的共享变量:广播变量,可用于在所有节点的内存中缓存一个值,以及累加器,它们是仅“添加”到的变量,例如计数器和总和。...但是,您也可以使用持久(或缓存)方法将 RDD 持久化在内存中,在这种情况下,Spark 会将元素保留在集群上,以便下次查询时更快地访问它。 还支持在磁盘上持久化 RDD,或跨多个节点复制。...请参阅 Spark 配置指南中的“随机播放行为”部分。 RDD持久化 Spark 中最重要的功能之一是跨操作将数据集持久化(或缓存)在内存中。...如果他们打算重用它,我们仍然建议用户在生成的 RDD 上调用persist。 选择什么样的存储级别 Spark 的存储级别旨在在内存使用和 CPU 效率之间提供不同的权衡。
的每次操作都会根据Task的类型转换成Task进行执行 Spark中关于RDD的介绍: 1....Spark的执行逻辑: Spark执行操作是通过RDD进行管理的,RDD保存的不是真实数据,而是一个任务代理,里面记录了数据的执行逻辑,类似PipeLine;并且...RDD在执行过程中产生的中间数据如果数据量小的话,是保存在内存中的,数据量大了以后也会保存近文件,这个RDD会自行判断处理。 ...MapReduce 的中间数据都会保存在文件,而Spark中间数据在内存中,处理起来会更加快。 3....SparkSubmit(Driver) 对数据进行汇总操作,比如Count;对于大数据是万万不能的,因为返回的数据可能是海量数据,全部放在Driver端导致Driver端不能处理而崩溃(数据量太大,直接导致内存
RDD的Transformation是指由一个RDD生成新RDD的过程,比如前面使用的flatMap、map、filter操作都返回一个新的RDD对象,类型是MapPartitionsRDD,它是RDD...RDD Transformation生成的RDD对象的依赖关系 除了RDD创建过程会生成新的RDD外,RDD Transformation也会生成新的RDD,并且设置与前一个RDD的依赖关系。...MapPartitionsRDD[U, T](this, (context, pid, iter) => iter.map(cleanF)) } MapPartitionsRDD的定义如下: private[spark...在Spark中,RDD是有依赖关系的,这种依赖关系有两种类型。 窄依赖。依赖上级RDD的部分分区。 Shuffle依赖。依赖上级RDD的所有分区。 对应类的关系如下图所示。...RDD仔细维护着这种依赖关系和计算方法,使得通过重新计算来恢复RDD成为可能。当然,这也不是万能的。如果依赖链条太长,那么通过计算来恢复的代价就太大了。所以,Spark又提供了一种叫检查点的机制。
RDD提供的是一种高度受限的共享内存模型,既RDD是只读的记录分区的集合,不能直接修改,只能给予文档sing的物理存储中的数据来创建RDD,或者是从其他RDD操作上执行转换操作得到新的RDD。...RDD特性 为什么RDD能实现高效计算? 高效的容错性。 分布式共享内存。键值存储、内存数据库等。为了实现容错必须在集群节点进行数据的复制,或者记录日志。...这样从开始到结束创建的RDD就会形成一幅血缘图.在这些转换的过程中我们会把中间结果持久化到内存,数据再内从中的多个RDD之间进行传递,不需要落地到磁盘上,但是内润空间不足 的时候,我们也可以利用磁盘的性能来进行消耗...但是Spark还提供了数据检查节点和记录日志,用于持久化数据RDD,减少追寻数据到最开始的RDD中。 3....阶段进行划分 Spark在运行过程中,是分析各个阶段的RDD形成DAG操作,在通过分析各个RDD之间的依赖关系来决定如何划分阶段。
Spark里的RDD是什么?在Spark如火如荼的今天,很多面试官都会问这个问题。想必答案大家都脱口而出--就是弹性分布式数据集嘛,但是它怎么就弹性了?它怎么分布式的?...它的partition分布在不同的节点上,因此RDD也是分布式的。 RDD的变换和依赖 Spark中的transform,就是在现有RDD的基础上构建新的RDD的过程。...使用 在运行spark的时候,将参数spark.logLineage设置为true,就可以输出RDD的Lineage object SparkApp { def main(args: Array[String...", true) .master("local") .getOrCreate() val rdd1 = spark.sparkContext.makeRDD(Seq(1,...2, 3, 4)) val rdd2 = spark.sparkContext.makeRDD(Seq(10, 20, 30, 40)) val result = rdd1.union
checkpoint算子不仅能将RDD持久化到磁盘,还能切断RDD之间的依赖关系。 cache 默认将RDD的数据持久化到内存中。cache是懒执行。...设置为只使用内存并序列化 scala> rdd.persist(StorageLevel.MEMORY_ONLY_SER) res1: org.apache.spark.rdd.RDD[String]...同时需要为需要持久化的RDD提供储存。Driver端的内存管理比较简单,这里所说的Spark内存管理针对Executor端的内存管理。...Spark内存管理分为静态内存管理和统一内存管理,Spark1.6之前使用的是静态内存管理,Spark1.6之后引入了统一内存管理。...静态内存管理中存储内存、执行内存和其他内存的大小在 Spark 应用程序运行期间均为固定的,但用户可以应用程序启动前进行配置。
RDD 概念与特性 RDD是Spark最重要的抽象。spark统一建立在抽象的RDD之上。设计一个通用的编程抽象,使得spark可以应对各种场合的大数据情景。...解决了mr的缺陷: 弹性分布式数据集Resilient Distributed Dataset 只读分区数据集,final修饰的 一个分布式的数据集合,是spark中的核心,spark的操作都是围绕...但是每个分区对应一个数据block 分区是个逻辑概念,新旧分区可能是同一块内存。(重要的优化,节约资源。)。在函数式编程,经常使用常量,但是很费内存,rdd的这种优化非常实用。...防止内存的无限性扩充 只是记录需要做的操作。只有当真正要执行的时候,才具体的执行 从路径读取的数据,可能有许多块,实际上RDD也是在各个区内执行的(解释了分布式),但是数据已经io到内存当中了。...spark用lineage的方式表示各个RDD的依赖关系,链表的表头是textFile 参考fp中的概念,这里只做逻辑运算,接受一个RDD,结果产生一个RDD,没有任何副作用 RDD常见的转化操作: map
RDD的Action是相对Transformation的另一种操作。...Transformation代表计算的中间过程,从一个RDD生成新的RDD;而Action代表计算的结束,一次Action调用之后,不再生成新的RDD,结果返回到Driver程序。...鉴于Action具有这样的特点,所以Action操作是不可以在RDD Transformation内部调用的。...比如,下面的调用是不允许的: rdd1.map(x => rdd2.values.count() * x) Transformation只是建立计算关系,而Action才是实际的执行者。...比如在count的实现中,先提交Job去集群上运行,返回结果到Driver程序,然后调用sum方法获取数量: /** * 返回RDD中的元素数RDD */ def count(): Long = sc.runJob
0x00 前言 本篇是Spark源码解析的第一篇,主要通过源码分析Spark设计中最重要的一个概念——RDD。...我们可以先大致这样理解RDD:RDD是一个容错的、并行的数据结构,可以让用户显式地将数据存储到磁盘和内存中,并能控制数据的分区。同时,RDD还提供了一组丰富的操作来处理这些数据。...private[spark] class MapPartitionsRDD[U: ClassTag, T: ClassTag]( var prev: RDD[T], f: (TaskContext.../** Returns the first parent RDD */ protected[spark] def firstParent[U: ClassTag]: RDD[U] = { dependencies.head.rdd.asInstanceOf...://www.infoq.com/cn/articles/spark-core-rdd/ http://bit1129.iteye.com/blog/2178322
RDD 本节首先给出 RDD 的详细定义,然后介绍下 Spark 的中针对 RDD 的操作接口,继而对比了 RDD 与提供细粒度更新接口的共享内存抽象优劣。最后就 RDD 的局限性讨论一下。...Spark 默认将 RDD 保存在内存中,如果内存不够用了会根据用户配置将数据溢出(spill)到硬盘上。...这些 workers 是分散在 Spark 集群内各个机器上的常驻进程,它们在内存里保存计算过程中生成的 RDD 的各个分区。...内存管理 Spark 提供了三种存储 RDD 的方式: 内存中没有序列化过的 Java 对象 内存中序列化过的数据 磁盘 由于 Spark 跑在 JVM 上,因此第一种存储方式访问最快,第二种允许用户牺牲一点性能以换取更高效的内存利用...现在每个 Spark 实例拥有自己的分立的内存空间,我们计划将来提供跨 Spark 实例的统一的内存管理。