R/spark_gen_embedded_sources.R

In sparklyr: R Interface to Apache Spark

spark_gen_embedded_sources <- function(
                                       output = file.path("java", "embedded_sources.R")) {
  worker_files <- sort(dir("R", full.names = TRUE, pattern = "worker|core"))
  lines <- unlist(lapply(worker_files, function(e) readLines(e)))
  lines <- c(lines, "do.call(spark_worker_main, as.list(commandArgs(trailingOnly = TRUE)))")

  writeLines(lines, output)
}