Join thông thường
Bạn được cung cấp hai DataFrame để gộp thành một DataFrame hữu ích. Nhiệm vụ đầu tiên của bạn là nối (join) hai DataFrame theo cách thông thường và xem kế hoạch thực thi.
Các DataFrame flights_df và airports_df đã sẵn sàng cho bạn sử dụng.
Bài tập này là một phần của khóa học
Làm sạch dữ liệu với PySpark
Hướng dẫn bài tập
- Tạo DataFrame mới
normal_dfbằng cách joinflights_dfvớiairports_df. - Xác định kiểu join được dùng trong kế hoạch truy vấn.
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.
# Join the flights_df and aiports_df DataFrames
normal_df = flights_df.____(____, \
flights_df["Destination Airport"] == airports_df["IATA"] )
# Show the query plan
normal_df.____()