pyspark.sql.DataFrame.toLocalIterator

DataFrame。 toLocalIterator ( prefetchPartitions:bool=假 )→迭代器(pyspark.sql.types.Row]

返回一個迭代器,包含所有的行DataFrame。迭代器將使用盡可能多的內存最大的分區DataFrame。預取它可能消耗2最大的內存分區。

參數

prefetchPartitions bool,可選

如果火花預取下一個分區之前是必要的。

例子

> > >列表(df。toLocalIterator())行(= 2歲name =“愛麗絲”)、行(= 5歲name = '鮑勃'))

以前的

pyspark.sql.DataFrame.toJSON

下一個

pyspark.sql.DataFrame.toPandas