File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -44,16 +44,22 @@ sparkR.init <- function(
4444 sparkHome = Sys.getenv(" SPARK_HOME" ),
4545 sparkEnvir = list (),
4646 sparkExecutorEnv = list (),
47- sparkJars = " " ) {
47+ sparkJars = " " ,
48+ sparkRLibDir = " " ) {
4849
4950 if (exists(" .sparkRjsc" , envir = .sparkREnv )) {
51+ cat(" Re-using existing Spark Context. Please restart R to create a new Spark Context\n " )
5052 return (get(" .sparkRjsc" , envir = .sparkREnv ))
5153 }
5254
5355 if (nchar(sparkHome ) != 0 ) {
5456 sparkHome <- normalizePath(sparkHome )
5557 }
5658
59+ if (nchar(sparkRLibDir ) != 0 ) {
60+ .sparkREnv $ libname <- sparkRLibDir
61+ }
62+
5763 sparkEnvirMap <- .jnew(" java/util/HashMap" )
5864 for (varname in names(sparkEnvir )) {
5965 sparkEnvirMap $ put(varname , sparkEnvir [[varname ]])
You can’t perform that action at this time.
0 commit comments