toLocalIterator

Vrátí iterátor, který obsahuje všechny řádky v tomto datovém rámci. Iterátor spotřebuje tolik paměti jako největší oddíl v tomto datovém rámci. Při předběžném načtení může spotřebovávat až paměť 2 největších oddílů.

Syntaxe

toLocalIterator(prefetchPartitions: bool = False)

Parametry

Parameter Typ Description
prefetchPartitions bool, volitelné Pokud má Spark předem načíst další oddíl před tím, než ho budete potřebovat.

Návraty

Iterátor: Iterátor řádků.

Příklady

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