조인 II
PySpark에서는 DataFrame 메서드 .join()을 사용해 조인을 수행합니다. 이 메서드는 세 가지 인수를 받습니다. 첫 번째는 첫 번째 DataFrame과 조인할 두 번째 DataFrame입니다. 두 번째 인수 on은 키 열 이름(들)을 문자열로 지정합니다. 키 열의 이름은 각 테이블에서 동일해야 합니다. 세 번째 인수 how는 수행할 조인의 종류를 지정합니다. 이 강의에서는 항상 how="leftouter" 값을 사용합니다.
flights 데이터셋과 airports라는 새 데이터셋이 워크스페이스에 준비되어 있습니다.
이 연습은 강의의 일부입니다
PySpark 기초
연습 안내
.show()를 호출해airportsDataFrame을 살펴보세요.airports를flights테이블과 조인할 때 사용할 키 열이 무엇인지 확인하세요.airports.withColumnRenamed("faa", "dest")의 결과를airports에 다시 할당해airports의faa열 이름을dest로 바꾸세요.flights에서.join()메서드를 호출해dest열을 기준으로airportsDataFrame과 조인하세요. 결과를flights_with_airports로 저장하세요.- 첫 번째 인수는 다른 DataFrame인
airports여야 합니다. on인수에는 키 열을 지정하세요.how인수에는"leftouter"를 사용하세요.
- 첫 번째 인수는 다른 DataFrame인
- 데이터를 다시 확인하기 위해
flights_with_airports에.show()를 호출하세요. 새로 추가된 정보를 확인해 보세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Examine the data
print(____)
# Rename the faa column
airports = ____
# Join the DataFrames
flights_with_airports = ____
# Examine the new DataFrame
print(____)