pyspark - Spark DataFrame 值更新

Question

刚开始在 AWS Glue 上检查某个列CASE_STATUS_ID的值是否为 3，如果是，则将其更改为 2，依此类推。这是动态帧代码：

datasource0 = glueContext.create_dynamic_frame.from_catalog(database = 
"etl_database", table_name = "case_data", transformation_ctx = "datasource0")

如果您能指出我检查当前值并使用if或case结构将其更新为所需值的方向，那将不胜感激。

标签： pyspark