pyspark.sql.DataFrame.foreachPartition

数据Frame foreachPartition 高山市 f级:Callable[[Iterator[pyspark.sql.types.Row]], None] )→ None

应用f级函数分治数据Frame.

速记本df.rdd.foreachPartition().

实例

>>>deff级高山市人间:.For人名内人间:.打印高山市人名.名称)>>>df.foreachPartition高山市f级)

前一

pyspark.sql.DataFrame.foreach

下一个

pyspark.sql.DataFrame.freqItems