DataFrame 조인하기
다음 두 챕터에서는 지금까지 다뤘던 항공편 데이터를 바탕으로 항공편이 지연될지 예측하는 모델을 만들어 볼 거예요. 이 모델에는 노선을 운항한 비행기에 대한 정보도 포함되므로, 첫 단계로 flights와 planes 두 테이블을 조인하겠습니다!
이 연습은 강의의 일부입니다
PySpark 기초
연습 안내
- 먼저, 중복된 열 이름을 피하기 위해
planes의year열을plane_year로 바꾸세요. tailnum열을 키로 사용해flights테이블과planes를 조인하여model_data라는 새 DataFrame을 만드세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Rename year column
planes = planes.withColumnRenamed(____)
# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")