Condividi tramite


toLocalIterator

Restituisce un iteratore che contiene tutte le righe in questo dataframe. L'iteratore utilizzerà la quantità di memoria maggiore della partizione più grande in questo dataframe. Con la prelettura può consumare fino alla memoria delle 2 partizioni più grandi.

Sintassi

toLocalIterator(prefetchPartitions: bool = False)

Parametri

Parametro Tipo Descrizione
prefetchPartitions bool, facoltativo Se Spark deve pre-recuperare la partizione successiva prima che sia necessaria.

Restituzioni

Iteratore: iteratore di righe.

Examples

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')]