Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Wendet die f Funktion auf jede Partition dieses DataFrame an.
Syntax
foreachPartition(f: Callable[[Iterator[Row]], None])
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
f |
Funktion | Eine Funktion, die einen Parameter akzeptiert, der jede zu verarbeitende Partition empfängt. |
Beispiele
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
def func(itr):
for person in itr:
print(person.name)
df.foreachPartition(func)