将列添加到sparkR中的DataFrame

Question

我想N在SparkR中的DataFrame中添加一个填充了字符的列.我会像非SparkR代码那样做:

df$new_column <- "N"

但是使用SparkR,我收到以下错误:

Error: class(value) == "Column" || is.null(value) is not TRUE

我已经尝试过疯狂的东西来管理它,我能够使用另一个(现有的)创建一个列df <- withColumn(df, "new_column", df$existing_column),但这个简单的事情,不...

有帮助吗？

谢谢.

Answer 1

直接的解决方案是使用SparkR::lit()功能:

df_new = withColumn(df, "new_column_name", lit("N"))