Приклад when()
Клаузула when() дає змогу умовно змінювати датафрейм на основі його вмісту. Потрібно змінити датафрейм voter_df, щоб додати випадкове число для кожного виборця, чия посада визначена як "Councilmember".
Дефініцію датафрейму voter_df уже надано, і він доступний для вас. Бібліотека pyspark.sql.functions доступна як F. Ви можете скористатися F.rand(), щоб згенерувати випадкове значення.
Ця вправа є частиною курсу
Очищення даних у PySpark
Інструкції до вправи
- Додайте до
voter_dfстовпецьrandom_valз результатами методуF.rand()для всіх виборців із посадою Councilmember. - Показуйте кілька рядків датафрейму та перевірте, чи спрацювала клаузула
.when().
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# 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.____