相反.join()pyspark

Question

join 返回包含具有匹配键的所有元素对的RDD.

https://spark.apache.org/docs/1.6.2/api/python/pyspark.html#pyspark.RDD.join

例:

 trueDupsRDD = (rdd1.join(rdd2))

我怎么能脱离？

我试过了:

notMatchingRDD = (rdd1.join(!rdd2))

Answer 1

用途subtractByKey:

返回C {self}中的每个(键,值)对,它们与C {other}中的匹配键没有对.

rdd1.subtractByKey(rdd2)