pyspark:pyspark.sql.utils列歧义

ejk8hzay 于 2021-07-13 发布在 Spark

关注(0)|答案(1)|浏览(332)

关闭。这个问题需要细节或清晰。它目前不接受答案。
**想改进这个问题吗？**通过编辑这个帖子来添加细节并澄清问题。

两个月前关门了。
改进这个问题

df = df.withColumn("ID", df["ID"].cast("int"))

df = df.withColumn("ID_Check" , when(df["ID"] == 1), 1).otherwise(0))

我变得模棱两可了。

ID could be : ID, ID.

不明白，我试过了 drop("ID") 但还是一样的问题。
我们如何解决这个问题

python apache-spark pyspark apache-spark-sql

来源：https://stackoverflow.com/questions/66310447/pyspark-pyspark-sql-utils-column-ambigous

1条答案

按热度按时间

4nkexdtk1#

试试这个：

from pyspark.sql.functions import col, when

df = df.withColumn("ID", col("ID").cast("int"))
df = df.withColumn("ID_Check" , when(col("ID") == 1), 1).otherwise(0))

赞(0）回复(0）举报 2021-07-13

我来回答

pyspark:pyspark.sql.utils列歧义

1条答案

相关问题

热门标签

最新问答