Nothing
#' @include globals.R
NULL
#' Dependencies and initialization procedures
#'
#' Functions in this file specify all runtime dependencies of sparklyr.flint
#' and package-wide constants in `.sparklyr.flint.globals`.
#'
#' @name init
NULL
spark_dependencies <- function(spark_version, scala_version, ...) {
if (spark_version < "2.0.0") {
stop("sparklyr.flint requires Spark 2.0 or higher")
}
pkg_name <- "org.sparklyr:sparklyr-flint_%s_%s:%s"
pkg_version <- "0.7.0"
pkg_spark_version <- if (spark_version < "3.0.0") "2-4" else "3-0"
if (!is.null(scala_version)) {
scala_version <- if (scala_version < "2.12") "2-11" else "2-12"
} else {
scala_version <- if (spark_version < "3.0.0") "2-11" else "2-12"
}
sparklyr::spark_dependency(
packages = c(
sprintf(
"org.clapper:grizzled-slf4j_%s:1.3.4",
gsub("-", ".", scala_version)
),
sprintf(pkg_name, pkg_spark_version, scala_version, pkg_version)
),
repositories = "https://github.com/org-sparklyr/sparklyr.flint/raw/maven2"
)
}
.onLoad <- function(libname, pkgname) {
sparklyr::register_extension(pkgname)
# initialize package-wide constants
constants <- list(
kValidTimeUnits = c(
"DAYS",
"HOURS",
"MINUTES",
"SECONDS",
"MILLISECONDS",
"MICROSECONDS",
"NANOSECONDS"
),
kDefaultTimeColumn = "time"
)
for (x in names(constants)) {
.sparklyr.flint.globals[[x]] <- constants[[x]]
lockBinding(sym = x, env = .sparklyr.flint.globals)
}
}
Any scripts or data that you put into this service are public.
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.