Dodaj kolumnę do DataFrame w sparkR

Question

Chciałbym dodać kolumnę wypełnioną znakiem N w DataFrame w SparkR. Chciałbym zrobić to tak z kodem non-SparkR:

df$new_column <- "N" 

Ale z SparkR, pojawia się następujący błąd:

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

próbowałam szalone rzeczy do zarządzania nim, udało mi się utwórz kolumnę przy użyciu innej (istniejącej) kolumny z df <- withColumn(df, "new_column", df$existing_column), ale ta prosta rzecz, nie ...

Każda pomoc?

Dzięki.

Answer 1

Prosta rozwiązaniem będzie użycie SparkR::lit() funkcję:

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