如何在pyspark中添加带有字符串常量的新列[重复]

【问题标题】：how to add new column with string constant in pyspark [duplicate]如何在pyspark中添加带有字符串常量的新列[重复]
【发布时间】：2017-10-03 06:27:18
【问题描述】：

如何将字符串值添加到 pyspark 中的列中。使用 withColumn("status","online") 会报错

我在这里使用的是 Spark 1.6

【问题讨论】：

【解决方案1】：

可以像下面这样添加一个新列

df.withColumn("status",df.online)

这可以像下面那样显式地转换为字符串类型

df.withColumn("status",df.online.cast("String"))

【讨论】：