Conditional DataFrame कॉलम ऑपरेशन

PySpark के साथ डेटा क्लीनिंग

Mike Metzger

Data Engineering Consultant

Conditional clauses

Conditional Clauses हैं:

  • if / then / else का इनलाइन रूप
  • .when()
  • .otherwise()
PySpark के साथ डेटा क्लीनिंग

शर्त वाला उदाहरण

.when(<if condition>, <then x>)

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

Name Age
Alice 14
Bob 18 Adult
Candice 38 Adult
PySpark के साथ डेटा क्लीनिंग

एक और उदाहरण

एक से अधिक .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
PySpark के साथ डेटा क्लीनिंग

Otherwise

.otherwise() वैसा ही है जैसा 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
PySpark के साथ डेटा क्लीनिंग

अभ्यास करते हैं!

PySpark के साथ डेटा क्लीनिंग

Preparing Video For Download...