When / Otherwise

Це завдання подібне до попереднього, але тепер потрібно додати різні значення залежно від посади виборця. Змініть датафрейм voter_df, щоб додавати випадкове число кожному учаснику голосування з посадою Councilmember. Використайте 2 для Mayor і 0 для будь-якої іншої посади.

Датафрейм voter_df уже створено й доступний. Бібліотека pyspark.sql.functions доступна як F. Ви можете використати F.rand() для генерації випадкового значення.

Ця вправа є частиною курсу

Очищення даних у PySpark

Переглянути курс

Інструкції до вправи

Додайте до voter_df стовпець random_val з результатами методу F.rand() для кожного виборця з посадою Councilmember. Для Mayor встановіть random_val рівним 2. Для будь-якої іншої посади встановіть значення 0.
Покажіть кілька рядків датафрейму та перевірте, чи спрацювали умови.
Використайте вираз .filter, щоб знайти значення 0 у random_val.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

# 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()

Редагувати та запускати код