如何在SparkR中编写函数？

Question

我最近开始使用sparkR。 我正在使用Rstudio服务器。 当我运行

rdd_str <- SparkR:::lapplyPartition(foo.keep_start, function(part){ 
part <- lapply(part, function(x) unlist(strsplit(x, ','))) 
part <- lapply(part, function(x) as.numeric(x[x != ''])) 
part 
}), 

没关系。

我想在一个应用对象13（库）去

libs <- c('cancel_count', 'cancel_refund', 'dead_count', 'dead_ratio.month', 
     'discount.month', 'firat_year_count', 'dead_count', 'foo.cancel', 
     'foo.keep_start', 'keep_count', 'pv.net', 'start_keep_count', 
     'tatal') 

怎么写功能？

Answer 1

要写上SparkR的功能，你可以做到这一点，如R.

Var<-function(params){ 
    ... 
}