การนำ UDF ไปใช้กับข้อมูลเวกเตอร์
มี DataFrame ชื่อ df ที่มีคอลัมน์ output ประเภท vector ให้พร้อมใช้งาน โดยแสดง 5 แถวแรกไว้ในคอนโซลแล้ว
นอกจากนี้ยังมี UDF ชื่อ get_first_udf ที่ใช้เลือกองค์ประกอบแรกของคอลัมน์เวกเตอร์
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Introduction to Spark SQL in Python
คำแนะนำการฝึกหัด
- สร้าง DataFrame ใหม่ชื่อ
df_newโดยเพิ่มคอลัมน์ใหม่ลงในdfและตั้งชื่อคอลัมน์ใหม่ว่าlabel - แสดง 5 แถวแรกของ
df_new
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Add label by applying the get_first_udf to output column
df_new = df.____('____', ____('____'))
# Show the first five rows
df_new.____