怎么创建RDD,具体的实现方式是怎样
Admin 2022-06-11 群英技术资讯 646 次浏览
Spark RDD 编程的程序入口对象是SparkContext对象(不论何种编程语言)。只有构建出SparkContext, 基于它才能执行后续的API调用和计算 。本质上, SparkContext对编程来说, 主要功能就是创建第一个RDD出来。
RDD的创建可以通过2种方式, 通过并行化集合创建( 本地对象转分布式RDD )和通过读取外部数据源( 读取文件)创建。
并行化创建是指将本地集合转向分布式RDD,这一步的创建是分布式的开端,将本地集合转化为分布式集合。
API如下
rdd=sparkcontext.parallelize(参数1,参数2) #参数1集合对象即可,比如list #参数2分区数完整代码:
# coding: utf8 from pyspark import SparkConf, SparkContext if __name__ = '__main__': # e.构建Spark执行环境 conf = SparkConf().setAppName("create rdd").\ setMaster("local[*]"] sc = SparkContext(conf = conf) # sc对象的parallelize方法, 可以将本地集合转换成RDD返回给你 data = [1, 2, 3, 4, 5, 6, 7, 8, 9] rdd = sc.parallelize(data, numSlices = 3) print(rdd.collect())
获取RDD分区数返回值是Int数字:getNumPartitions API
用法rdd.getNumPartitions()
textFile API
这个API可以读取本地数据,也可以读取hdfs数据
使用方法:
sparkcontext.textFile(参数1,参数2) #参数1,必填,文件路径支持本地文件支持HDFS也支持一些比如S3协议 #参数2,可选,表示最小分区数量。 #注意:参数2话语权不足,spark有自己的判断,在它允许的范围内,参数2有效果,超出spark允许的范围,参数2失效完整代码
1f __nane__ = '__main__: # B.构建Spark执行环境 conf = SparkConf().setAppNane("create rdd").\ setMaster("local[*]") sc = SparkContext(conf=conf) # textFile API 读取文件 rdd = sc.textFile(".…/data/words.txt", 1000) print(rdd.getNumPartitions()) rdd2 = sc.textFile("hdfs://nodel:8020/input/words.txt", 1888) #最小分区数给了1060,但是实际就开了85个, spark没有理会你要求最少1008的要求,而是尽是多开。 print(rdd2.getNumPartitions()) print(rdd2.collect())
注意:textFile除非有很明确的指向性,一般情况下,我们不是指分区参数。
读取文件的API,有个小文件读取专用场景:适合读取一堆小文件
用法:
sparkcontext.wholeTextFiles(参数1,参数2) #参数1,必填,文件路径支持本地文件支持HDFS也支持一些比如S3协议 #参数2,可选,表示最小分区数量。 #注意:参数2话语权不足,这个API分区数量最多也只能开到文件数量
这个API偏向于少量分区读取数据,因为这个API表明了自己是小文件读取专用,那么文件的数据很小。分区很多,导致shuffle的几率更高.所以尽量少分区读取数据。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
SPLIT 运算符用于将关系拆分为两个或多个关系。语法下面给出了 SPLIT 运算符的语法。grunt> SPLIT Relation1_name INTO Relation2_name IF (condition1), Relation2_name (condition2)
什么是Apache Pig?Apache Pig是MapReduce的一个抽象。它是一个工具/平台,用于分析较大的数据集,并将它们表示为数据流。Pig通常与 Hadoop 一起使用;我们可以使用Apache Pig在Hadoop中执行所有的数据处理操作
大数据剖析技能有哪些?大数据时代,每天都有海量的数据产生,我们想要从中获取到对我们有用处的信息,大数据剖析有很大的帮助。因此这篇文章就给大家来简单的介绍一下大数据剖析技能,感兴趣的朋友就继续往下看吧。
在本章中,我们将了解如何以批处理模式运行Apache Pig脚本。Pig脚本中的注释在将脚本写入文件时,我们可以在其中包含注释,如下所示。多行注释我们将用'/*'开始多行注释,以'*/'结束。/*
配置hadoop之前做好准备工作1.修改主机名称,我这里创建了三个虚拟主机,分别命名node-1,node-2,node-3,进入 network 文件删掉里面的内容直接写上主机名就可以了vi /etc/sysconfig/network2.映射 IP 和主机名,之后 reboot 重启主机
成为群英会员,开启智能安全云计算之旅
立即注册Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008