You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2021/11/19 00:50:51 UTC
[spark] branch branch-3.0 updated: [MINOR][R][DOCS] Fix minor issues in SparkR docs examples
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 45c84ca [MINOR][R][DOCS] Fix minor issues in SparkR docs examples
45c84ca is described below
commit 45c84cad3ab67cac23e64085953cf34fbb19fc8e
Author: zero323 <ms...@gmail.com>
AuthorDate: Fri Nov 19 09:47:17 2021 +0900
[MINOR][R][DOCS] Fix minor issues in SparkR docs examples
### What changes were proposed in this pull request?
This PR fixes two minor problems in SpakR `examples`
- Replace misplaced standard comment (`#`) with roxygen comment (`#'`) in `sparkR.session` `examples`
- Add missing comma in `write.stream` examples.
### Why are the changes needed?
- `sparkR.session` examples are not fully rendered.
- `write.stream` example is not syntactically valid.
### Does this PR introduce _any_ user-facing change?
Docs only.
### How was this patch tested?
Manual inspection of build docs.
Closes #34654 from zero323/sparkr-docs-fixes.
Authored-by: zero323 <ms...@gmail.com>
Signed-off-by: Hyukjin Kwon <gu...@apache.org>
(cherry picked from commit 207dd4ce72a5566c554f224edb046106cf97b952)
Signed-off-by: Hyukjin Kwon <gu...@apache.org>
---
R/pkg/R/DataFrame.R | 2 +-
R/pkg/R/sparkR.R | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/R/pkg/R/DataFrame.R b/R/pkg/R/DataFrame.R
index 4195ec8f..952b8e3 100644
--- a/R/pkg/R/DataFrame.R
+++ b/R/pkg/R/DataFrame.R
@@ -3896,7 +3896,7 @@ setMethod("isStreaming",
#' # console
#' q <- write.stream(wordCounts, "console", outputMode = "complete")
#' # text stream
-#' q <- write.stream(df, "text", path = "/home/user/out", checkpointLocation = "/home/user/cp"
+#' q <- write.stream(df, "text", path = "/home/user/out", checkpointLocation = "/home/user/cp",
#' partitionBy = c("year", "month"), trigger.processingTime = "30 seconds")
#' # memory stream
#' q <- write.stream(wordCounts, "memory", queryName = "outs", outputMode = "complete")
diff --git a/R/pkg/R/sparkR.R b/R/pkg/R/sparkR.R
index e4a11a5..14a1ada 100644
--- a/R/pkg/R/sparkR.R
+++ b/R/pkg/R/sparkR.R
@@ -369,7 +369,7 @@ sparkRHive.init <- function(jsc = NULL) {
#' c("one.jar", "two.jar", "three.jar"),
#' c("com.databricks:spark-avro_2.12:2.0.1"))
#' sparkR.session(spark.master = "yarn", spark.submit.deployMode = "client",
-# spark.executor.memory = "4g")
+#' spark.executor.memory = "4g")
#'}
#' @note sparkR.session since 2.0.0
sparkR.session <- function(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org