pyspark.RDD.filter

抽樣。 過濾器 ( f:可調用的((T],bool] )→pyspark.rdd.RDD(T]

返回一個新的抽樣僅包含滿足謂詞的元素。

例子

> > >抽樣=sc。並行化([1,2,3,4,5])> > >抽樣。過濾器(λx:x%2= =0)。收集()(2、4)

以前的

pyspark.RDD.distinct

下一個

pyspark.RDD.first