手机网站js电话悬浮,wordpress转载视频,网站和网店的区别,南昌网站建设维护文章目录 1、count算子功能语法 2、foreach算子功能语法 3、saveAsTextFile算子功能语法 4、first算子功能语法举例 1、count算子
功能 统计RDD集合中元素的个数#xff0c;返回一个int值 语法
def count(self) - int2、foreach算子
功能 对RDD中每个元素调用一次参数中… 文章目录 1、count算子功能语法 2、foreach算子功能语法 3、saveAsTextFile算子功能语法 4、first算子功能语法举例 1、count算子
功能 统计RDD集合中元素的个数返回一个int值 语法
def count(self) - int2、foreach算子
功能 对RDD中每个元素调用一次参数中的函数没有返回值【与map场景上的区别】 语法
def map(self , f: T - U ) - None3、saveAsTextFile算子
功能 用于将RDD的数据保存到外部文件系统中 语法
def saveAsTextFile(self , path ) - None4、first算子
功能
返回RDD集合中的第一个元素【RDD有多个分区返回的是第一个分区的第一个元素】
语法
def first(self) - T举例
如何构造sc对象并创建RDD 参考文章 【Spark中创建RDD的两种方式】Spark中如何获取sc对象、以及创建RDD的两种方式
rdd1 sc.parallelize([1,2,3,4,5,6,7,8,9],numSlices3)
print(rdd1.first()) # 输出结果为 1
