如何在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){ 
    ... 
}