BaşlayınÜcretsiz başlayın

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, kursun bir parçasıdır

PySpark ile Veri Temizleme

Kursa Göz Atın

Egzersiz talimatları

  • Councilmember unvanına sahip her seçmen için F.rand() metodunun sonucuyla random_val adlı bir sütunu voter_df’e ekle.
  • .when() ifadesinin çalışıp çalışmadığını not ederek DataFrame’in bazı satırlarını göster.

Uygulamalı etkileşimli egzersiz

Bu egzersizi bu örnek kodu tamamlayarak deneyin.

# 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.____
Kodu Düzenle ve Çalıştır