R/utils.R

spark_expect_jobj_class <- get("spark_expect_jobj_class",
                               envir = asNamespace("sparklyr"))

spark_normalize_path <- get("spark_normalize_path",
                            envir = asNamespace("sparklyr"))

spark_sqlresult_from_dplyr <- get("spark_sqlresult_from_dplyr",
                                  envir = asNamespace("sparklyr"))
chezou/sparkavro documentation built on June 5, 2020, 10:18 a.m.