Pyspark将值替换为空条件值

2024-06-30 15:03:23 发布

您现在位置：Python中文网/ 问答频道 /正文
1187 3

我需要用pyspark中的空值替换我的异常值

df = df.withColumn("rpm", when(df["rpm"] >= 750, None).otherwise(df["rpm"]))

但是我得到了这个错误：

TypeError: condition should be a Column

Tags： nonedf错误columnbeconditionpysparkwhen
1条回答
网友
1楼 · 发布于 2024-06-30 15:03:23

安基的上述评论有效。谢谢

df.withColumn("rpm", when(col("rpm") >= 750, None).otherwise(col("rpm")))

相关问题 更多 >

    编程相关推荐