R/vs_connect.R

In r-spark/variantspark: A 'Sparklyr' Extension for 'VariantSpark'

#' Creating a variantspark connection
#' 
#' You need to create a variantspark connection to use this extension. To do this, 
#' you pass as argument a spark connection that you can create 
#' using \code{sparklyr::spark_connect()}. 
#' 
#' @param sc A spark connection.
#' 
#' @return A variantspark connection
#' 
#' @examples 
#' library(sparklyr)
#' sc <- spark_connect(master = "spark://HOST:PORT")
#' connection_is_open(sc)
#' vsc <- vs_connect(sc)
#' spark_disconnect(sc)
#'
#' @export
vs_connect <- function(sc){
  sparklyr::invoke_new(sc, "au.csiro.variantspark.api.VSContext", spark_session(sc))
}