如何在Pyspark中使用字符串常数添加新列



如何在pyspark中的列中添加字符串值。使用with column("状态","在线"(给出错误

我在这里使用Spark 1.6

可以像下面的

那样添加一个新列
df.withColumn("status",df.online)

可以将其施放到字符串类型中,例如以下

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

最新更新