pyspark.RDD.foreachPartition

抽樣。 foreachPartition ( f:可調用的[[Iterable [T]],沒有) )→沒有

一個函數適用於每個分區的抽樣。

例子

> > >deff(迭代器):…為x在迭代器:…打印(x)> > >sc。並行化([1,2,3,4,5])。foreachPartition(f)

以前的

pyspark.RDD.foreach

下一個

pyspark.RDD.fullOuterJoin