Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Devuelve un iterador que contiene todas las filas de este DataFrame. El iterador consumirá tanta memoria como la partición más grande de este DataFrame. Con la captura previa, puede consumir hasta la memoria de las 2 particiones más grandes.
Sintaxis
toLocalIterator(prefetchPartitions: bool = False)
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
prefetchPartitions |
bool, opcional | Si Spark debe capturar previamente la siguiente partición antes de que sea necesaria. |
Devoluciones
Iterador: iterador de filas.
Ejemplos
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
list(df.toLocalIterator())
# [Row(age=14, name='Tom'), Row(age=23, name='Alice'), Row(age=16, name='Bob')]