Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
Alkalmazza a függvényt a f DataFrame összes sorára.
Szemantika
foreach(f: Callable[[Row], None])
Paraméterek
| Paraméter | Típus | Leírás |
|---|---|---|
f |
függvény | Egy függvény, amely egy paramétert fogad el, amely minden egyes feldolgozandó sort fogad. |
Examples
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
def func(person):
print(person.name)
df.foreach(func)