Operazioni condizionali sulle colonne del DataFrame

Pulizia dei dati con PySpark

Mike Metzger

Data Engineering Consultant

Clausole condizionali

Le clausole condizionali sono:

  • Versione inline di if / then / else
  • .when()
  • .otherwise()
Pulizia dei dati con PySpark

Esempio con condizione

.when(<condizione if>, <allora x>)

df.select(df.Name, df.Age, F.when(df.Age >= 18, "Adult"))

Name Age
Alice 14
Bob 18 Adult
Candice 38 Adult
Pulizia dei dati con PySpark

Altro esempio

Più .when()

df.select(df.Name, df.Age, 
          .when(df.Age >= 18, "Adult")
          .when(df.Age < 18, "Minor"))
Name Age
Alice 14 Minor
Bob 18 Adult
Candice 38 Adult
Pulizia dei dati con PySpark

Otherwise

.otherwise() è come else

df.select(df.Name, df.Age,
          .when(df.Age >= 18, "Adult")
          .otherwise("Minor"))
Name Age
Alice 14 Minor
Bob 18 Adult
Candice 38 Adult
Pulizia dei dati con PySpark

Passiamo alla pratica!

Pulizia dei dati con PySpark

Preparing Video For Download...