Pandas UDFs
이번 연습 문제에서는 Pandas UDF의 문법을 직접 연습해 봅니다. 진행하면서 이전 연습 문제에서 사용한 PySpark UDF와 이번 Pandas UDF의 차이점을 살펴보세요.
작업 공간에는 이미 SparkSession인 spark가 준비되어 있어요!
이 연습은 강의의 일부입니다
PySpark 입문
연습 안내
add_ten_pandas()함수를 pandas UDF로 정의하세요.- pandas UDF를 DataFrame
df의"value"열에 적용해"10_plus"라는 새 열을 추가하세요. - 결과 DataFrame을 출력해 보세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Define a Pandas UDF that adds 10 to each element in a vectorized way
@____(DoubleType())
def add_ten_pandas(column):
return column + 10
# Apply the UDF and show the result
df.withColumn("10_plus", ____)
df.____