Join các chuyến bay với sân bay điểm đến
Bạn vừa được tuyển dụng làm kỹ sư dữ liệu cho một công ty du lịch toàn cầu. Nhiệm vụ đầu tiên của bạn là giúp công ty cải thiện vận hành bằng cách phân tích dữ liệu chuyến bay. Trong không gian làm việc của bạn có hai bộ dữ liệu: một bộ chứa chi tiết về các chuyến bay (flights) và một bộ chứa thông tin về các sân bay điểm đến (airports), cả hai đều đã sẵn sàng trong workspace của bạn.
Mục tiêu của bạn? Kết hợp hai bộ dữ liệu này để tạo ra một tập dữ liệu mạnh, liên kết từng chuyến bay với sân bay điểm đến tương ứng.
Bài tập này là một phần của khóa học
Nhập môn PySpark
Hướng dẫn bài tập
- Xem DataFrame
airports. Xác định cột khóa nào cho phép bạn joinairportsvào bảngflights. - Join
flightsvới DataFrameairportstrên cột"dest". Lưu kết quả làflights_with_airports. - Xem lại
flights_with_airports. Lưu ý thông tin mới đã được thêm vào.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Examine the data
airports.____()
# .withColumnRenamed() renames the "faa" column to "dest"
airports = airports.withColumnRenamed("faa", "dest")
# Join the DataFrames
flights_with_airports = ____
# Examine the new DataFrame
flights_with_airports.____