.Spark中有哪些常用的算子？

Transformation（转换操作）：
map(func)：将每个元素都传递给函数func进行处理，返回一个新的RDD。
filter(func)：返回满足条件的元素组成的新RDD。
flatMap(func)：与map类似，但是返回的是一个扁平化的结果。
union(otherRDD)：返回两个RDD的并集。
distinct([numTasks]))：返回一个去重后的RDD。
groupByKey([numTasks])：将具有相同key的元素进行分组。
reduceByKey(func, [numTasks])：将具有相同key的元素进行reduce操作。
sortByKey([ascending],[numTasks])：按照key进行排序。
Action（动作操作）：
count()：返回RDD中元素的个数。
collect()：将RDD的所有元素返回到driver端，可能会导致内存溢出。
first()：返回RDD中的第一个元素。
take(n)：返回RDD中的前n个元素。
reduce(func)：对RDD中的元素进行reduce操作，func接收两个参数。
foreach(func)：将RDD中的每个元素传递给函数func进行处理。