例如,我正在寻找与sparkR中R中的mapvalues
函数等效的方法>
x <- c("a", "b", "c") mapvalues(x, c("a", "c"), c("A", "C"))
我在Scala中找到了等效的功能,例如this。但是我在sparkR的documentation中找不到它。
编辑:
linked doumentation中有一个称为map_values
的函数:
##D # Dataframe used throughout this doc df <- createDataFrame(cbind(model = rownames(mtcars), mtcars)) tmp3 <- mutate(df, v3 = create_map(df$model, df$cyl)) head(select(tmp3, map_keys(tmp3$v3), map_values(tmp3$v3))) head(select(tmp3, element_at(tmp3$v3, "Valiant")))
但是使用方式不同,
map_values
和map_keys
都使用在创建它们的同一列中:“ v3”不像我可以使用变量v3再次映射来自建模为圆柱。
我正在寻找与sparkR中R中的mapvalues函数等效的函数,例如x
不幸的是,Spark函数map_values与R函数mapvalues非常不同。它从映射返回值,而不是映射值。