Apache spark 的一些浅见。

一、搬砖 vs. 分布式计算

一个人搬砖很累,几个人一起搬就会轻松很多,也会快很多:

分布并行计算和几个人一起搬砖的意思是一致的,一个资源密集型的任务(搬砖或计算),需要 一组资源(小伙伴或计算节点),并行地完成:

  • 计算任务 => 搬砖
  • 计算节点 => 小伙伴

当计算任务过重时,我们就把计算任务拆分,然后放到多个计算节点上同时执行,这就是分布并行计算。

二、求文件中包含"包租婆"的行数

从一个总计100行的文件中找出所有包含“包租婆”的行数,我们不用太动脑筋就有一个算法:

  1. 读一行,判断这一行有“包租婆”吗?如果有,全局变量count加1。
  2. 文件到末尾了吗?如果没有,跳转到第1步继续执行。
  3. 打印count。

这几步程序,我打赌在你的计算机上可以一眨眼的功夫就执行完。但是如果这个文件有100万行呢? 如果还用刚才不动脑筋的笨算法,可能就不好交差了......

并行分布计算采用了一个大智若愚的办法,通过将笨算法丢给一群机器同时去算,实现规定时间内规定 任务的完成。你要知道,如今流行的Map/Reduce就是这么干的,这听起来不够高端,也确实引起了一些数据库专 家(聪明人)的非议。不过,不管黑猫白猫,能抓住老鼠的都是好猫。

三、Spark简化了分布式计算的开发

如果要把刚才的任务进行分布计算(假设有10台机器可以用),需要对原始的笨算法做一些调整:

  1. 把100万条数据分成10份,每份10万条。
  2. 在10台机器上分别执行笨办法计算包含“包租婆”的行数。
  3. 汇总合并10台机器的计算结果,即count,打印出来。

Oh...NO.....太...累...了...

好在有Spark的存在!我们只要把数据和计算程序交给Spark,它会机智地进行数据切分、算法复制、分布执行、结果合并。

四、Spark的计算范式:数据集上的计算

Spark用起来的确简单,但有一点特别要注意,你得按照Spark的范式写算法。

Spark是在数据集的层次上进行分布并行计算,是的,它只认成堆的数据:

我们提交给Spark的计算任务,必须满足两个条件:

  1. 数据是可以分块的,每块构成一个集合。
  2. 算法只能在集合级别执行操作。

比如,对于文本文件,在Spark中,一行就是一条记录,若干条记录组成一个集合。我们 原来的算法直接在每一行上进行计算,就不行了。需要先构建数据集,然后通过数据集的操作, 实现我们的目的。

五、SQL中的数据集

如果你熟悉SQL,可以用SQL的思维考虑下什么是集合操作:

  1. UPDATE USER SET GENDER=‘FEMALE‘

上面的SQL语句就是一个集合操作,对一个数据集合,执行一条UPDATE操作,整个数据集都被修改了。

UPDATE语句有两个特点,这也是集合操作的要素:

1.对集合的每个记录执行相同的操作

UPDATE更新了集合中的所有记录,这些记录的 GENDER 字段值都被更新为 FEMALE 。

2.这个操作的具体行为是用户指定的

UPDATE通过SET子句,指定更新那些字段,怎么更新。

六、JavaScript中的数据集

JavaScript中数组对象的map方法也是一种集合操作。map方法将一个数组的每一个成员变换为新的成员, 并返回变换后新的集合。

  1. var a=[1,2,3,4];
    a.map(function(d){return d*2;});
    console.log(a);

上面的JavaScript代码对一个数组执行map方法,将每一个成员进行倍乘。结果是获得一个新的 数组,比如在这里,将得到[2,4,6,8]。

这个例子也说明了集合操作的两个要素:

1.对集合的每个记录执行相同的操作

在map方法执行中,每个数组成员都被转换为原始值的2倍。

2.这个操作的具体行为是用户指定的

map方法使用一个匿名函数,指定如何对每一个原始数据进行变换。

七、将算法移植到Spark上

现在我们修改原始的笨算法,使之适用于Spark:

  1. 将数据载入并构造数据集
    在Spark中,这个数据集被称为`RDD` :弹性分布数据集。
  2. 对数据集进行map操作
    指定行为:如果一行原始记录包含“包租婆”,该行记录映射为新值1,否则映射为新值0 。
  3. 对map后的数据集进行collect操作,获得合并的结果。

上面的map操作,和前面JavaScript数组的map方法类似,将原始记录映射为新的记录,并返回一个新的RDD。 collect操作提取RDD中的全部数据到本地。

魔术发生在RDD上。Spark的RDD自动进行数据的切分和结果的整合。我们假装不知道就好了, 就像这一切只发生在本地的一台机器上。

八、Spark操作符

Spark提供了80多种操作符对集合进行操作。我们列举常用的一些供你建立一点基本概念, 以便了解Spark可以支持什么:

变换

变换操作总是获得一个新的RDD:

  • map(func) : 将原始数据集的每一个记录使用传入的函数func ,映射为一个新的记录,并返回新的RDD。
  • filter(func) : 返回一个新的RDD,仅包含那些符合条件的记录,即func返回true 。
  • flatMap(func) : 和map类似,只是原始记录的一条可能被映射为新的RDD中的多条。
  • union(otherDataset) : 合并两个RDD,返回一个新的RDD 。
  • intersection(otherDataset):返回一个新的RDD,仅包含两个RDD共有的记录。

动作

动作操作总是获得一个本地数据,这意味着控制权回到你的程序了:

  • reduce(func) : 使用func对RDD的记录进行聚合。
  • collect() : 返回RDD中的所有记录
  • count() : 返回RDD中的记录总数

对spark中Scala语言快速扫盲、交互分析、RDD动作、RDD变换的介绍如下:
http://www.hubwiz.com/course/5449c691e564e50960f1b7a9/

时间: 2024-11-05 19:51:49

Apache spark 的一些浅见。的相关文章

Apache Spark 1.4 读取 hadoop 2.6 文件系统上文件

scala> val file = sc.textFile("hdfs://9.125.73.217:9000/user/hadoop/logs") scala> val count = file.flatMap(line => line.split(" ")).map(word => (word,1)).reduceByKey(_+_) scala> count.collect() 以Spark上经典的wordcount为例,验证sp

mllib:Exception in thread "main" org.apache.spark.SparkException: Input validation failed.

当我们使用mllib做分类,用到逻辑回归或线性支持向量机做分类时,可能会出现下面的错误: 15/04/09 21:27:25 ERROR DataValidators: Classification labels should be 0 or 1. Found 3000000 invalid labels Exception in thread "main" org.apache.spark.SparkException: Input validation failed. 由于做调试时

Apache Spark技术实战之1 -- KafkaWordCount

欢迎转载,转载请注明出处,徽沪一郎. 概要 Spark应用开发实践性非常强,很多时候可能都会将时间花费在环境的搭建和运行上,如果有一个比较好的指导将会大大的缩短应用开发流程.Spark Streaming中涉及到和许多第三方程序的整合,源码中的例子如何真正跑起来,文档不是很多也不详细. 本篇主要讲述如何运行KafkaWordCount,这个需要涉及Kafka集群的搭建,还是说的越仔细越好. 搭建Kafka集群 步骤1:下载kafka 0.8.1及解压 wget https://www.apach

3 分钟学会调用 Apache Spark MLlib KMeans

Apache Spark MLlib是Apache Spark体系中重要的一块拼图:提供了机器学习的模块.不过,目前对此网上介绍的文章不是很多.拿KMeans来说,网上有些文章提供了一些示例程序,而这些程序基本和Apache Spark 官网上的程序片断类似:在得到训练模型后,几乎都没有展示如何使用该模型.程序执行流程.结果展示以及举例测试数据等部分.笔者根据Apache Spark官网上的程序片断,写了一个完整的调用MLlib KMeans库的测试程序,并成功在Spark 1.0 + Yarn

Apache Spark源码走读之12 -- Hive on Spark运行环境搭建

欢迎转载,转载请注明出处,徽沪一郎. 楔子 Hive是基于Hadoop的开源数据仓库工具,提供了类似于SQL的HiveQL语言,使得上层的数据分析人员不用知道太多MapReduce的知识就能对存储于Hdfs中的海量数据进行分析.由于这一特性而收到广泛的欢迎. Hive的整体框架中有一个重要的模块是执行模块,这一部分是用Hadoop中MapReduce计算框架来实现,因而在处理速度上不是非常令人满意.由于Spark出色的处理速度,有人已经成功将HiveQL的执行利用Spark来运行,这就是已经非常

Spark-->combineByKey【请阅读Apache spark官网文档】

这篇文章,很有必要看,写的不错.但是看过后,不要忘记查看Apache spark官网.因为这篇文章理解还是和源码.官网文档 不一致.有一点错误![cnblogs的代码编辑器 不支持Scala,所以 语言的关键字 没有高亮显示] 在数据分析中,处理Key,Value的Pair数据是极为常见的场景,例如我们可以针对这样的数据进行分组.聚合或者将两个包含Pair数据的RDD根据key进行join.从函数的抽象层面看,这些操作具有共同的特征,都是将类型为RDD[(K,V)]的数据处理为RDD[(K,C)

Apache Spark探秘:三种分布式部署方式比较

目前Apache Spark支持三种分布式部署方式,分别是standalone.spark on mesos和 spark on YARN,其中,第一种类似于MapReduce 1.0所采用的模式,内部实现了容错性和资源管理,后两种则是未来发展的趋势,部分容错性和资源管理交由统一的资源管理系统完成:让Spark运行在一个通用的资源管理系统之上,这样可以与其他计算框架,比如MapReduce,公用一个集群资源,最大的好处是降低运维成本和提高资源利用率(资源按需分配).本文将介绍这三种部署方式,并比

Apache Spark技术实战之3 -- Spark Cassandra Connector的安装和使用

欢迎转载,转载请注明出处,徽沪一郎. 概要 前提 假设当前已经安装好如下软件 jdk sbt git scala 安装cassandra 以archlinux为例,使用如下指令来安装cassandra yaourt -S cassandra 启动cassandra cassandra -f 创建keyspace和table, 运行/usr/bin/cqlsh进入cql console,然后执行下述语句创建keyspace和table CREATE KEYSPACE test WITH repli

Apache Spark源码走读之13 -- hiveql on spark实现详解

欢迎转载,转载请注明出处,徽沪一郎 概要 在新近发布的spark 1.0中新加了sql的模块,更为引人注意的是对hive中的hiveql也提供了良好的支持,作为一个源码分析控,了解一下spark是如何完成对hql的支持是一件非常有趣的事情. Hive简介 Hive的由来 以下部分摘自Hadoop definite guide中的Hive一章 "Hive由Facebook出品,其设计之初目的是让精通SQL技能的分析师能够对Facebook存放在HDFS上的大规模数据集进行分析和查询. Hive大大