Podmíněné operace se sloupci DataFrame

Cleaning Data with PySpark

Mike Metzger

Data Engineering Consultant

Podmíněné klauzule

Podmíněné klauzule jsou:

  • Inline verze if / then / else
  • .when()
  • .otherwise()
Cleaning Data with PySpark

Příklad podmínky

.when(<podmínka>, <hodnota>)

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

Name Age
Alice 14
Bob 18 Adult
Candice 38 Adult
Cleaning Data with PySpark

Další příklad

Více .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
Cleaning Data with PySpark

Otherwise

.otherwise() funguje jako 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
Cleaning Data with PySpark

Pojďme procvičovat!

Cleaning Data with PySpark

Preparing Video For Download...