Mulai sekarangMulai gratis

Contoh when()

Klausa when() memungkinkan Anda memodifikasi DataFrame secara kondisional berdasarkan isinya. Anda akan memodifikasi DataFrame voter_df untuk menambahkan sebuah angka acak pada setiap anggota pemilih yang didefinisikan sebagai "Councilmember".

DataFrame voter_df sudah didefinisikan dan tersedia untuk Anda. Pustaka pyspark.sql.functions tersedia sebagai F. Anda dapat menggunakan F.rand() untuk menghasilkan nilai acak.

Latihan ini merupakan bagian dari kursus

Membersihkan Data dengan PySpark

Lihat Kursus

Instruksi latihan

  • Tambahkan kolom ke voter_df bernama random_val dengan hasil dari metode F.rand() untuk setiap pemilih dengan jabatan Councilmember.
  • Tampilkan beberapa baris DataFrame, dan periksa apakah klausa .when() berhasil.

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

# 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.____
Edit dan Jalankan Kode