เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

การ join แบบปกติ

มี DataFrame สองตัวให้นำมารวมกันเป็น DataFrame เดียวที่นำไปใช้งานได้ ขั้นแรกให้รวม DataFrame ทั้งสองแบบปกติ แล้วดู execution plan

DataFrame flights_df และ airports_df พร้อมใช้งานแล้ว

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

การทำความสะอาดข้อมูลด้วย PySpark

ดูคอร์ส

คำแนะนำการฝึกหัด

  • สร้าง DataFrame ใหม่ชื่อ normal_df โดย join flights_df กับ airports_df
  • ตรวจสอบว่า query plan ใช้การ join ประเภทใด

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ

ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์

# 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.____()
แก้ไขและรันโค้ด