二零二三年 优质公开课substract算子.pptx

substract算子 substract算子介绍示例 /01基本介绍substract算子介绍 def subtract(other: RDD[T]): RDD[T]def subtract(other: RDD[T], numPartitions: Int): RDD[T]def subtract(other: RDD[T], partitioner: Partitioner)(implicit ord: Ordering[T] = null): RDD[T]该函数类似于intersection，但返回在RDD中出现，并且不在otherRDD中出现的元素，不去重。 参数含义同intersection。substract算子介绍 /02基本介绍示例 将两个RDD进行合并不去重，代码如下：示例（一） 实现一个类似于集合A-B的操作：示例（二）接收一个RDD[T]，或者再传入分区数，或者自己定义的Partitioner。 substract算子介绍示例展示