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

ตัวอย่างการใช้ when()

คำสั่ง when() ช่วยให้แก้ไข DataFrame ตามเงื่อนไขของข้อมูลได้ เราจะเพิ่มค่าสุ่มให้กับสมาชิกที่มีตำแหน่งเป็น "Councilmember" ใน DataFrame ชื่อ voter_df

voter_df ถูกกำหนดไว้และพร้อมใช้งานแล้ว ไลบรารี pyspark.sql.functions พร้อมใช้งานในชื่อ F. โดยสามารถใช้ F.rand() เพื่อสร้างค่าสุ่มได้

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

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

ดูคอร์ส

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

  • เพิ่มคอลัมน์ชื่อ random_val ใน voter_df โดยใช้ F.rand() สำหรับผู้ลงคะแนนที่มีตำแหน่งเป็น Councilmember
  • แสดงแถวบางส่วนของ DataFrame เพื่อตรวจสอบว่าคำสั่ง .when() ทำงานถูกต้องหรือไม่

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

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

# Add a column to voter_df for any voter with the title **Councilmember**
voter_df = voter_df.____('random_val',
                               ____(____, ____))

# Show some of the DataFrame rows, noting whether the when clause worked
voter_df.____
แก้ไขและรันโค้ด