when() örneği
when() ifadesi, içeriğine bağlı olarak bir DataFrame’i koşullu biçimde değiştirmeni sağlar. "Councilmember" olarak tanımlanan herhangi bir oy kullanma üyesine rastgele bir sayı eklemek için voter_df DataFrame’ini değiştireceksin.
voter_df DataFrame’i tanımlandı ve kullanımına hazır. pyspark.sql.functions kütüphanesi F. olarak mevcut. Rastgele değer üretmek için F.rand() kullanabilirsin.
Bu egzersiz
PySpark ile Veri Temizleme
kursunun bir parçasıdırEgzersiz talimatları
- Councilmember unvanına sahip her seçmen için
F.rand()metodunun sonucuylarandom_valadlı bir sütunuvoter_df’e ekle. .when()ifadesinin çalışıp çalışmadığını not ederek DataFrame’in bazı satırlarını göster.
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# 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.____