Skip to content

Commit fdd38c5

Browse files
committed
Added the changes to write.df and saveDF too
1 parent faa4971 commit fdd38c5

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

R/pkg/R/DataFrame.R

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1975,7 +1975,13 @@ setMethod("write.df",
19751975
signature(df = "DataFrame", path = "character"),
19761976
function(df, path, source = NULL, mode = "error", ...){
19771977
if (is.null(source)) {
1978-
sqlContext <- get(".sparkRSQLsc", envir = .sparkREnv)
1978+
if (exists(".sparkRSQLsc", envir = .sparkREnv)) {
1979+
sqlContext <- get(".sparkRSQLsc", envir = .sparkREnv)
1980+
} else if (exists(".sparkRHivesc", envir = .sparkREnv)) {
1981+
sqlContext <- get(".sparkRHivesc", envir = .sparkREnv)
1982+
} else {
1983+
stop("sparkRHive or sparkRSQL context has to be specified")
1984+
}
19791985
source <- callJMethod(sqlContext, "getConf", "spark.sql.sources.default",
19801986
"org.apache.spark.sql.parquet")
19811987
}

R/pkg/R/generics.R

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -531,11 +531,11 @@ setGeneric("transform", function(`_data`, ...) {standardGeneric("transform") })
531531

532532
#' @rdname write.df
533533
#' @export
534-
setGeneric("write.df", function(df, path, ...) { standardGeneric("write.df") })
534+
setGeneric("write.df", function(df, path, source = NULL, mode = "error", ...) { standardGeneric("write.df") })
535535

536536
#' @rdname write.df
537537
#' @export
538-
setGeneric("saveDF", function(df, path, ...) { standardGeneric("saveDF") })
538+
setGeneric("saveDF", function(df, path, source = NULL, mode = "error", ...) { standardGeneric("saveDF") })
539539

540540
#' @rdname write.json
541541
#' @export

0 commit comments

Comments
 (0)