pyspark.RDD.intersection

抽樣。 十字路口 ( 其他:pyspark.rdd.RDD(T] )→pyspark.rdd.RDD(T]

返回這個抽樣的十字路口和另一個。輸出將不會包含任何重複的元素,即使輸入抽樣。

筆記

這個方法執行內部洗牌。

例子

> > >rdd1=sc並行化([1,10,2,3,4,5])> > >rdd2=sc並行化([1,6,2,3,7,8])> > >rdd1十字路口(rdd2)收集()(1、2、3)