Pyspark - 用空条件替换值
Pyspark - Replace value with Null Conditional
我需要用 pyspark 中的空值替换异常值
df = df.withColumn("rpm", when(df["rpm"] >= 750, None).otherwise(df["rpm"]))
但是我得到这个错误：
TypeError: condition should be a Column
Anky 上面的评论有效。谢谢
df.withColumn("rpm", when(col("rpm") >= 750, None).otherwise(col("rpm")))
我需要用 pyspark 中的空值替换异常值
df = df.withColumn("rpm", when(df["rpm"] >= 750, None).otherwise(df["rpm"]))
但是我得到这个错误：
TypeError: condition should be a Column
Anky 上面的评论有效。谢谢
df.withColumn("rpm", when(col("rpm") >= 750, None).otherwise(col("rpm")))