DataFrame列の条件付き操作

PySpark でデータをクレンジングする

Mike Metzger

Data Engineering Consultant

条件句

条件句 とは:

.when(<条件>, <なら x>)

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

複数の .when()

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

.otherwise() は else のように動作

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

PySpark でデータをクレンジングする