แปลงข้อมูล

ยอดเยี่ยม! ตอนนี้พร้อมแล้วที่จะส่งข้อมูลผ่าน Pipeline ที่สร้างไว้

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

พื้นฐาน PySpark

สร้าง DataFrame ชื่อ piped_data โดยเรียก method .fit() และ .transform() ของ Pipeline ต่อกันเป็น chain โดย method ทั้งสองรับ model_data เป็นอาร์กิวเมนต์เดียว

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

# Fit and transform the data
piped_data = flights_pipe.____.____