Exemplu cu when()

Clauza when() îți permite să modifici condiționat un DataFrame în funcție de conținutul său. Vei adăuga un număr aleatoriu în DataFrame-ul voter_df pentru orice membru votant cu titlul „Councilmember".

DataFrame-ul voter_df este definit și disponibil. Biblioteca pyspark.sql.functions este disponibilă sub aliasul F. Poți folosi F.rand() pentru a genera valoarea aleatorie.

Acest exercițiu face parte din cursul

Curățarea datelor cu PySpark

Vezi cursul

Instrucțiuni pentru exercițiu

Adaugă o coloană numită random_val în voter_df, cu rezultatele metodei F.rand(), pentru orice alegător cu titlul Councilmember.
Afișează câteva rânduri din DataFrame și verifică dacă clauza .when() a funcționat corect.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# 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.____

Editează și rulează codul