Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Tillämpar funktionen på f varje partition i dataramen.
Syntax
foreachPartition(f: Callable[[Iterator[Row]], None])
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
f |
function | En funktion som accepterar en parameter som tar emot varje partition att bearbeta. |
Exempel
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
def func(itr):
for person in itr:
print(person.name)
df.foreachPartition(func)