如何解决在 Nullif 的表达式中使用变量失败
我正在使用下面的代码将空字符串转换为 Null。
我没有收到错误,但它仍然是一个空字符串。
我怀疑在 col_name
expr
for col_name in ['col1','col2']:
df_new = df \
.withColumn(col_name,F.expr(f"nullif('{col_name}','')"))
解决方法
你真正想做的是这个。请注意,for 循环将创建并覆盖 df_new
,因此只会更改最后一列。
from pyspark.sql import functions as f
df_new = df
for col_name in ['col1','col2']:
df_new = df_new.withColumn(col_name,f.expr(f"nullif({col_name},'')"))
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。