前言
算子是spark中处理数据的重要的计算单元，RDD 根据数据处理方式的不同将算子整体上分为 Value 类型、双 Value 类型和 Key-Value类型；
Map使用
map在spark的数据转换中有着重要的作用，开发中几乎离不开map的使用，基本语法：
def map[U: ClassTag](f:
T => U
): RDD[
U
]
函数说明：
- 将处理的数据逐条进行映射转换，这里的转换可以是类型的转换，也可以是值的转换
案例1
自定义一个List集合，将集合中的每个元素前面拼接一个字符串
import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.rdd.RDD
object MapRdd_1 {
def main(args: Array[String]): Unit = {
val sparkConf = new版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由半码博客整理，本文链接：https://www.bmabk.com/index.php/post/143258.html