Spark环境搭建、运行模式、RDD简单操作

妖狐艹你老母 2023-01-20 15:58 56阅读 0赞

安装一个简单的伪分布式Spark集群及RDD简单操作  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70]

### 文章目录 ###

*  实验环境
 *  实验原理
 *   *  安装配置
     *  环境监控
 *  安装前的环境准备
 *   *  关闭spark服务
     *  解压Scala安装包
     *  配置环境变量
 *  解压Spark安装包，添加配置
 *   *  解压Spark安装包
 *  启动spark集群
 *  Spark运行模式
 *   *  本地模式
     *  standalone模式
     *  开启PySpark
 *  RDD基本操作
 *   *  从集合创建RDD
     *  元素转化操作
     *  元素行动操作

# 实验环境 #

前提是已经配置好Java、Hadoop了

1.  环境：Linux
2.  安装包版本：

*  scala-2.11.8.tgz
 *  spark-2.1.0
 *  jdk1.8.0\_171
 *  hadoop-2.6.0

spark: [http://spark.apache.org/downloads.html][http_spark.apache.org_downloads.html]  
scala: [https://www.scala-lang.org/download/2.11.8.html][https_www.scala-lang.org_download_2.11.8.html]

1.  安装包存放路径：/usr/local

# 实验原理 #

## 安装配置 ##

安装过程其实很简单，Spark是一个计算框架，功能就和Hadoop的MapReduce一样，Hadoop的MapReduce是不需要启动的，因MapReduce只是提供了一组计算的API，使用Yarn作为资源调度就行。

## 环境监控 ##

Spark集群配置好以后，可以使用sbin目录下的start-all.sh启动集群。启动集群后，可以使用浏览器就行查看，master的默认端口是8080，学会使用浏览器进行监控能够方便我们很多操作。

# 安装前的环境准备 #

## 关闭spark服务 ##

*  本次实验为安装一个简单的伪分布式Spark集群，环境中已经配置好Java、Hadoop，如果是真实环境中，则需要三台至多台服务器，这里只进行简单配置安装学习。在安装Spark之前还需要安装Scala，因为Spark是scala开发，所以scala是需要配置的。解压安装Scala，解压后文件依然存放在/usr/local下。
 *  使用命令查看进程，可以看到已经开启开启多个服务，实验中我们关闭spark相关服务，练习spark的安装和开启。

1.  查看所有进程服务：jps
2.  关闭spark服务：/usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0/sbin/stop-all.sh
3.  查看进程：jps  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 1]

## 解压Scala安装包 ##

首先进入/usr/local文件夹下查看我们需要的安装包，然后进行解压安装

*  查看local下列表：ls /usr/local
 *  解压scala： tar -zxvf /usr/local/scala-2.11.8.tgz -C /usr/local/![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 2]

## 配置环境变量 ##

配置环境变量，添加Scala的安装路径

1.  编辑配置文件：vim /etc/profile  
    编辑如下：

export SCALA_HOME=/usr/local/scala-2.11.8
    export PATH=${SCALA_HOME}/bin:${SCALA_HOME}/sbin:$PATH

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 3]

1.  保存退出，生效配置文件让其立刻生效。然后再运行scala进行验证。
2.  生效变量：`source /etc/profile`
3.  开启scala：`scala`  
    示例验证，为x赋值为5，然后退出scala：

scala> var x =5
    sacal> :quit

![在这里插入图片描述][20210518111101763.png]

# 解压Spark安装包，添加配置 #

## 解压Spark安装包 ##

1.  Spark安装文件在/usr/local/下面，使用命令解压到 /usr/local/下面：

tar zxvf /usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0.tgz -C /usr/local

1.  解压完成后,同样在~/bashrc中添加SPARK\_HOME环境变量，同时将bin目录和sbin目录添加到PATH路径下。

export SPARK_HOME=/usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0
    export PATH=${
        SPARK_HOME}/sbin:${
        SPARK_HOME}/bin:$PATH

注意使用source命令使其生效。

生效环境变量：`source /etc/profile`

1.  修改spark配置文件  
    修改Spark的配置文件，首先将spark-env.sh.templete复制为spark-env.sh，在里面配置：JAVA\_HOME、SPARK\_MASTER\_IP、HADOOP\_CONF\_DIR,注意保存。

*  进入spark配置目录：cd $SPARK\_HOME/conf/
 *  查看当前路径：pwd
 *  查看当前目录下所有配置文件：ls
 *  将自带的template样例文件复制为配置文件：cp spark-env.sh.template spark-env.sh
 *  编辑配置文件：vim spark-env.sh  
    ![在这里插入图片描述][2021051412131287.png]

export JAVA_HOME=/usr/local/java/jdk1.8.0_171
    export SPARK_MASTER_IP=localhost
    export HADOOP_CONF_DIR=/usr/local/hadoop-2.6.0-cdh5.7.0/etc/hadoop

![在这里插入图片描述][20210514121544734.png]

# 启动spark集群 #

启动集群，查看进程 。因为spark执行程序在spark/sbin目录下，当前在spark的配置目录conf路径下，因此可以退到sa

*  退回上一层：cd …
 *  命令：sbin/start-all.sh
 *  命令：jps  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 4]  
    启动伪集群之后，可以看到其进程显示启动了master和worker。说明伪机群搭建时，服务器是主节点，也是从节点。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70_pic_center]

当然Spark也提供了浏览器端口供我们监控spark节点的状态。可以直接访问主节点master的8080端口进行查看

# Spark运行模式 #

## 本地模式 ##

• 首先进入spark目录：`cd /usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0`  
• 开启本地模式：`./bin/spark-shell --master local[2]`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 5]

## standalone模式 ##

在交互式Shell中Spark应用程序，需运行下面的命令：  
• 开启单机模式：`./bin/spark-shell --master spark://10.135.0.54:7077（注意修改IP）`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 6]

## 开启PySpark ##

PySpark 是 Spark 为 Python 开发者提供的 API。位于 $SPARK\_HOME/bin 目录，其依赖于 Py4J。其开启方法如下：  
• 开启pyspark：.`/bin/pyspark --master local[2]`  
• 退出：`exit()`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 7]

# RDD基本操作 #

## 从集合创建RDD ##

1.  首先开启spark，然后进入Spark shell交互界面  
    • 进入spark目录：`cd /usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0/`  
    • 进入spark交互界面：`bin/spark-shell`
2.  通过并行化集合来创建RDD  
    针对程序中的集合，调用SparkContext中的parallelize()方法。Spark会将集合中的数据拷贝到集群上去，形成一个分布式的数据集合，也就是一个RDD

![在这里插入图片描述][20210518111935564.png]

1.  使用makeRDD创建RDD  
    该用法可以指定每一个分区的preferredLocations。操作如下：  
    ![在这里插入图片描述][20210518111952355.png]

## 元素转化操作 ##

1.  首先开启spark，然后进入Spark shell交互界面  
    • 进入spark目录：`cd /usr/local/spark-2.1.0-bin-2.6.0-cdh5.7.0/`  
    • 进入spark交互界面：`bin/spark-shell`  
    对一个数据\{1，2，3，3\}的RDD进行基本的RDD转化操作

scala> val arr = Array(1,2,3,3) ##创建一个集合
    scala> val rdd = sc.parallelize(arr) ##并行化操作RDD

1.  `map()`将函数应用于RDD中的每个元素，将返回新的RDD  
    ![在这里插入图片描述][20210518112237861.png]
2.  `flatMap()`将函数应用于RDD中的每个元素，将返回的迭代器的所有元素构成的RDD，通常用于切分单词  
    ![在这里插入图片描述][20210518112308105.png]
3.  `filter()`过滤，结果返回一个由通过传给filter()的函数的元素组成的RDD。  
    ![在这里插入图片描述][20210518112315690.png]
4.  `distinct()`去重。  
    ![在这里插入图片描述][20210518112321732.png]
5.  `sample`(withRepalcement,fraction,\[seed\])对RDD采样 ，以及是否替换。withRepalcement 是否为放回（不重复），fraction为数量。结果是非确定的，产生一般的数据。

![在这里插入图片描述][20210518112327576.png]

## 元素行动操作 ##

1.  `collect()：`返回RDD中的所有元素。  
    rdd.collect()  
    ![在这里插入图片描述][20210518112951964.png]
2.  `count()：`RDD中的元素个数。  
    rdd.count()  
    ![在这里插入图片描述][20210518112901255.png]
3.  `countByValue()：`各结果在RDD中出现的次数。  
    rdd.countByValue()
4.  `take(num)：`从RDD中返回num个元素。  
    rdd.take(2)
5.  `top(num)：`从RDD中返回前面的num个元素。  
    rdd.top(2)  
    ![在这里插入图片描述][2021051811302395.png]  
    ![在这里插入图片描述][20210518113030476.png]
6.  `takeSample`(withReplacement,num,\[seed\]) 从RDD中返回任意一些元素（非确定）。  
    rdd.takeSample(false,1)
7.  `fold(zero)`(func)：和reduce一样，但是需要提供初始值。  
    rdd.fold(0)((x,y) => x+y)
8.  `aggregate(zeroValue)`(seq0p,comb0p) 和reduce类似但是通常返回不同的数据  
    rdd.aggregate((0,0))((x,y) => (x.\_1 + y,x.\_2 +1 ),(x,y) => (x.\_1 + y.\_1, x.\_2 + y.\_2))  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_30_color_FFFFFF_t_70]

> 到这里就结束了，如果对你有帮助，欢迎点赞关注评论，你的点赞对我很重要，author：北山啦

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70]: /images/20221021/840cf89e63644f088eafebe15720887a.png
[http_spark.apache.org_downloads.html]: http://spark.apache.org/downloads.html
[https_www.scala-lang.org_download_2.11.8.html]: https://www.scala-lang.org/download/2.11.8.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 1]: /images/20221021/8a5f7ac2f01447c3b02187ea6158c3ff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 2]: /images/20221021/bfae49afa5c44cc198b97a6b6ebcee64.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 3]: /images/20221021/1ff776480c374c8cbd668bc4bf8b2e70.png
[20210518111101763.png]: /images/20221021/e81a0a9521ff477eab934b72773ddd46.png
[2021051412131287.png]: /images/20221021/810db754c8d8499dabeb9f8063f5f7d8.png
[20210514121544734.png]: /images/20221021/b2c6b29226564fa599cf8be0ee9a783c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 4]: /images/20221021/542d8f13761f4b56bf4b0b2f51de663a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70_pic_center]: /images/20221021/14487ce8c16d4925bd290abc7a86651c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 5]: /images/20221021/99b93883dfdb417bb1d21d27d5758c1c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 6]: /images/20221021/1870decc651943a19ade1f9a0eab62a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_16_color_FFFFFF_t_70 7]: /images/20221021/09099c031b944c4db6163026e14a16ee.png
[20210518111935564.png]: /images/20221021/b0e2d7b3aa174193960ce43e76603694.png
[20210518111952355.png]: /images/20221021/0217509b546f48c790b9b86f307c7f85.png
[20210518112237861.png]: /images/20221021/947b1ecbaaf64df6920e48951dfddcc2.png
[20210518112308105.png]: /images/20221021/3e6997e6ee1242488bef8618f3588127.png
[20210518112315690.png]: /images/20221021/a1822c8268c242acab47b3f786069428.png
[20210518112321732.png]: /images/20221021/7d5464536b144634a11583a4f0d3657c.png
[20210518112327576.png]: /images/20221021/debe203a88a04817a85da035afa172a9.png
[20210518112951964.png]: /images/20221021/29e38ee298334f1c83e44454615f5d84.png
[20210518112901255.png]: /images/20221021/2065382b728248c3b94d87e807dc27e3.png
[2021051811302395.png]: /images/20221021/e481cd5eb8bc481d9aa8ddd8eea909ba.png
[20210518113030476.png]: /images/20221021/5e86ebe884814a55a860d4a9d8b3ce8b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1MTc2NTQ4_size_30_color_FFFFFF_t_70]: /images/20221021/14862718dd5b4a9f9ccedbe23edd8e12.png