pyspark.RDD.flatMap

抽樣。 flatMap ( f:可調用的((T],Iterable(U]],preservesPartitioning:bool=假 )→pyspark.rdd.RDD(U]

返回一個新的抽樣,首先將一個函數應用於所有元素的抽樣,然後壓扁的結果。

例子

> > >抽樣=sc。並行化([2,3,4])> > >排序(抽樣。flatMap(λx:範圍(1,x))。收集())(1,1,1,2,2,3]> > >排序(抽樣。flatMap(λx:((x,x),(x,x)))。收集())[(2,2),(2,2),(3),(3),(4,4),(4,4)]

以前的

pyspark.RDD.first

下一個

pyspark.RDD.flatMapValues