spark RDD的核心技术
发布时间
阅读量:
阅读量
RDD 是一种不可更改的分布式对象集合。
生成 RDD 的方式包括:1)通过读取外部数据集(如使用 SparkContext.textFile() 方法);
2)在驱动程序中,将一个集合进行并行化处理。
RDD 操作类型 包括:1)转化操作(transformation):此类操作会基于一个已有的 RDD 生成一个新的 RDD;
2)行动操作(action):此类操作会对 RDD 进行计算,得出结果后将其返回至驱动程序,或存储至外部存储系统(如 HDFS)中。
转化操作 包括:union()、filter() 等;
行动操作 包括:count()、take()、collect() 等;
filter 用于从 RDD 中筛选符合条件的数据;
union 用于对两个不同的 RDD 进行合并操作;
count 用于统计 RDD 中元素的总数;
take 用于获取 RDD 中少量的数据样本;
collect 则用于提取 RDD 中所有的数据内容。
转化操作与行动操作之间的主要差异 在于 Spark 对 RDD 的计算方式存在不同 ,其中转化操作返回的是新的 RDD,而 行动操作则返回其他形式的数据类型 。
所有 RDD 的转化操作均采用惰性求值机制。这意味着,在调用任何行动操作之前,Spa
全部评论 (0)
还没有任何评论哟~
