RDD 的分区和 Shuffle 查看分区 | 学习笔记

简介: 快速学习 RDD 的分区和 Shuffle 查看分区

开发者学堂课程【大数据Spark2020最新课程(知识精讲与实战演练)第二阶段RDD 的分区和 Shuffle 查看分区学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/689/detail/11991


RDD 的分区和 Shuffle 查看分区


内容介绍

一、查看分区的方法

二、验证

 

一、查看分区的方法

本节继续学习 RDD 的分区和 Shuffle 的过程,讲解如何查看分区。

第一种方式通过 webui 的方式:

首先进入 shell 窗口:

image.png

因为有一些分区操作放在集群里更直观。

编写命令如下:

cd/export/servers/spark

bin/spark-shell --master local[6]

//通过 master 指定 spark shell 的交互式窗口,交互式窗口的运行的位置呢,可以指定 local,也可以指定spark//node01等等。为了便于我们的控制,所以呢,我们直接指定 local[6] 就可以,指定6个分区。

打开 spark

image.png

注意:其中的 Spark context available as'sc 创建了一个对象,叫做 SC,类型是 spark context

Spark context Web UI available athttp://172.21.0.11:4040

//sparkshell 为我们提供了一个 ui 4040的端口上。

继续编写代码:

val rdd1 = sc.parallelize(Seq(12345678910))

拿到 RDD 对象:

image.png

通过创建 RDD并不能直接执行 RDD,只能拿到一个 RDD 对象,执行 RDD 需要调用 RDD1中的 action

每一次调用 action,就会生成一个 job 放在集群当中。第二步就是分阶段,每个阶段叫做一个 stages 。接下来先调用 collect。执行,

rdd1.collect()

获取到结果如下:

image.png

然后通过浏览器打开 node01 4040端口:

image.png

此处指 RDD 6个分区,在开启 spark shell 窗口时,指定的 master local[6] 。然后  :quit  退出。

猜测:通过 local[6] 来开启 spark shell ,默认创建一个 ID 时,就会有六个分区。接下来验证想法。

 

二、验证

编写代码:

bin/spark-shell --master local[8]

指定 local[8]

image.png

val rdd1 = sc.parallelize(Seq(12345678910))

image.png

rdd1.collect()

再次进入浏览器打开 node01 4040端口:

image.png

默认分区变为8。证明猜测正确。

第二种查看分区的方法:

rdd1.partitions

rdd1.partitions.size

可以查看集合数量,通过 size 查看有8个分区,partition 这个集合中保留分区的信息。

image.png

查看分区的2种方式:

1.  通过 webui 的方式。

2.   通过partitions的方式。

相关文章
|
存储 缓存 文件存储
如何保证分布式文件系统的数据一致性
分布式文件系统需要向上层应用提供透明的客户端缓存,从而缓解网络延时现象,更好地支持客户端性能水平扩展,同时也降低对文件服务器的访问压力。当考虑客户端缓存的时候,由于在客户端上引入了多个本地数据副本(Replica),就相应地需要提供客户端对数据访问的全局数据一致性。
33252 201
如何保证分布式文件系统的数据一致性
|
设计模式 存储 监控
设计模式(C++版)
看懂UML类图和时序图30分钟学会UML类图设计原则单一职责原则定义:单一职责原则,所谓职责是指类变化的原因。如果一个类有多于一个的动机被改变,那么这个类就具有多于一个的职责。而单一职责原则就是指一个类或者模块应该有且只有一个改变的原因。bad case:IPhone类承担了协议管理(Dial、HangUp)、数据传送(Chat)。good case:里式替换原则定义:里氏代换原则(Liskov 
36821 22
设计模式(C++版)
|
存储 编译器 C语言
抽丝剥茧C语言(初阶 下)(下)
抽丝剥茧C语言(初阶 下)
|
机器学习/深度学习 人工智能 自然语言处理
带你简单了解Chatgpt背后的秘密:大语言模型所需要条件(数据算法算力)以及其当前阶段的缺点局限性
带你简单了解Chatgpt背后的秘密:大语言模型所需要条件(数据算法算力)以及其当前阶段的缺点局限性
24905 16
|
机器学习/深度学习 弹性计算 监控
重生之---我测阿里云U1实例(通用算力型)
阿里云产品全线降价的一力作,2023年4月阿里云推出新款通用算力型ECS云服务器Universal实例,该款服务器的真实表现如何?让我先测为敬!
36824 15
重生之---我测阿里云U1实例(通用算力型)
|
SQL 存储 弹性计算
Redis性能高30%,阿里云倚天ECS性能摸底和迁移实践
Redis在倚天ECS环境下与同规格的基于 x86 的 ECS 实例相比,Redis 部署在基于 Yitian 710 的 ECS 上可获得高达 30% 的吞吐量优势。成本方面基于倚天710的G8y实例售价比G7实例低23%,总性价比提高50%;按照相同算法,相对G8a,性价比为1.4倍左右。
|
存储 算法 Java
【分布式技术专题】「分布式技术架构」手把手教你如何开发一个属于自己的限流器RateLimiter功能服务
随着互联网的快速发展,越来越多的应用程序需要处理大量的请求。如果没有限制,这些请求可能会导致应用程序崩溃或变得不可用。因此,限流器是一种非常重要的技术,可以帮助应用程序控制请求的数量和速率,以保持稳定和可靠的运行。
29949 52

热门文章

最新文章