Cómo crear una nueva columna con Spark_Aply
library(sparklyr)
sc <- spark_connect(master = "local")
df <- sdf_len(sc, 100)
df <- sdf_repartition(df, 5) %>%
spark_apply(function(df){
df['new']<-df$id * 10
df
})
Trustworthy Whale