pyspark.sql.DataFrame.foreachPartition

DataFrame。 foreachPartition ( f:可調用的[[[pyspark.sql.types迭代器。行]],沒有) )→沒有

應用f函數的每個分區DataFrame。

這個縮寫df.rdd.foreachPartition ()。

例子

> > >deff(人):…為人在人:…打印(人。的名字)> > >df。foreachPartition(f)

以前的

pyspark.sql.DataFrame.foreach

下一個

pyspark.sql.DataFrame.freqItems