Skip to content

Commit 28916fc

Browse files
committed
undo job group changes
1 parent 345b9e2 commit 28916fc

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

R/pkg/NAMESPACE

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,11 @@ exportMethods("glm",
2525
"spark.naiveBayes",
2626
"spark.survreg")
2727

28+
# Job group lifecycle management methods
29+
export("setJobGroup",
30+
"clearJobGroup",
31+
"cancelJobGroup")
32+
2833
# Export Utility methods
2934
export("setLogLevel")
3035

R/pkg/R/sparkR.R

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -396,7 +396,6 @@ sparkR.session <- function(
396396
#' @param groupid the ID to be assigned to job groups
397397
#' @param description description for the job group ID
398398
#' @param interruptOnCancel flag to indicate if the job is interrupted on job cancellation
399-
#' @noRd
400399
#' @examples
401400
#'\dontrun{
402401
#' sc <- sparkR.init()
@@ -410,7 +409,6 @@ setJobGroup <- function(sc, groupId, description, interruptOnCancel) {
410409
#' Clear current job group ID and its description
411410
#'
412411
#' @param sc existing spark context
413-
#' @noRd
414412
#' @examples
415413
#'\dontrun{
416414
#' sc <- sparkR.init()
@@ -425,7 +423,6 @@ clearJobGroup <- function(sc) {
425423
#'
426424
#' @param sc existing spark context
427425
#' @param groupId the ID of job group to be cancelled
428-
#' @noRd
429426
#' @examples
430427
#'\dontrun{
431428
#' sc <- sparkR.init()

0 commit comments

Comments
 (0)