이 DataFrame의 f 모든 행에 함수를 적용합니다.
문법
foreach(f: Callable[[Row], None])
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
f |
기능 | 처리할 각 행을 수신하는 하나의 매개 변수를 허용하는 함수입니다. |
예제
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
def func(person):
print(person.name)
df.foreach(func)