他の列に基づいてPySparkの列を更新するには？

Question

"CUSTOMER_MAILID"、 "OFFER_NAME"、 "OFFER_ISAPPLIED"という列を持つデータフレームがあります。

サンプルデータ：

+--------------------+--------------------+---------------+ 
|  CUSTOMER_MAILID|   OFFER_NAME|OFFER_ISAPPLIED| 
+--------------------+--------------------+---------------+ 
|pushpendrakaushik...|Jaipur Pink Panth...|    N| 
|pushpendrakaushik...|Jaipur Pink Panth...|    N| 
|dr.kshitijmathur@...|     |    N| 
|spdadhichassociat...|     |    N| 
|vinod.gogia@herom...|Jaipur Pink Panth...|    N| 
|prerak0401@gmail.com|     |    N| 
| garhwalsp@gmail.com|     |    N| 
|muditsharma1985@g...|     |    N| 
| amit1185@gmail.com|Jaipur Pink Panth...|    N| 

私は "OFFER_NAME" 列がNullを除き、いくつかの値を持っている場合は、 "Y" と "OFFER_ISAPPLIED" 列の値を更新します。

どうすれば達成できますか？

出力は次のようにする必要があります：

+--------------------+--------------------+---------------+ 
|  CUSTOMER_MAILID|   OFFER_NAME|OFFER_ISAPPLIED| 
+--------------------+--------------------+---------------+ 
|pushpendrakaushik...|Jaipur Pink Panth...|    Y| 
|pushpendrakaushik...|Jaipur Pink Panth...|    Y| 
|dr.kshitijmathur@...|     |    N| 
|spdadhichassociat...|     |    N| 
|vinod.gogia@herom...|Jaipur Pink Panth...|    Y| 
|prerak0401@gmail.com|     |    N| 
| garhwalsp@gmail.com|     |    N| 
|muditsharma1985@g...|     |    N| 
| amit1185@gmail.com|Jaipur Pink Panth...|    Y| 

Answer 1

用途：

from pyspark.sql.functions import * 

df.withColum("OFFER_ISAPPLIED", 
    when(col("OFFER_NAME").isNull(), "N").otherwise("Y"))