1. Learn
    2. /
  2. Курси
    3. /
  3. Очищення даних у PySpark
Connected

Вправа

When / Otherwise

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

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

Інструкції

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