计算Spark R字符数的语法



在R中,我们使用str_length((进行相同的操作,Spark R中类似操作的语法是什么。

R语法

str_length(10)
2
str_length(9)
1
df <- data.frame(x = c("abc", "abcdef"))

SparkR中,使用length

library(SparkR)
df_sparkr <- createDataFrame(df)
head(select(df_sparkr, length(df_sparkr$x)))
#>   length(x)
#> 1         3
#> 2         6

sparklyr中,使用nchar

library(tidyverse)
library(sparklyr)
sc <- sparklyr::spark_connect(method = "local")
df_sparklyr <- copy_to(sc, df)
df_sparklyr %>%
mutate(length = nchar(x))
#> # Source: spark<?> [?? x 2]
#>   x      length
#>   <chr>   <int>
#> 1 abc         3
#> 2 abcdef      6

您可以使用此nchar(string)

最新更新