When / Otherwise

Kebutuhan ini mirip dengan yang sebelumnya, tetapi kini Anda ingin menambahkan beberapa nilai berdasarkan posisi pemilih. Ubah DataFrame voter_df untuk menambahkan angka acak pada setiap anggota pemungutan suara yang berposisi sebagai Councilmember. Gunakan nilai 2 untuk Mayor dan 0 untuk posisi lainnya.

Data Frame 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. Atur random_val menjadi 2 untuk Mayor. Atur jabatan lainnya ke nilai 0.
Tampilkan beberapa baris Data Frame, periksa apakah klausa tersebut bekerja.
Gunakan klausa .filter untuk menemukan nilai 0 di random_val.

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

# Add a column to voter_df for a voter based on their position
voter_df = voter_df.____('random_val',
                               when(voter_df.TITLE == 'Councilmember', ____)
                               .____(____, 2)
                               ____

# Show some of the DataFrame rows
voter_df.show()

# Use the .filter() clause with random_val
voter_df.____(____).show()

Edit dan Jalankan Kode