R/etl_load.R

In wantpinow/NYC-Taxicab-Package: ETL : NYCTaxicab

#' @inheritParams etl_load.etl_NYCTaxicab
#' @import etl
#' @importFrom DBI dbWriteTable
#' @importFrom methods is
#' @importFrom utils download.file
#' @method etl_load etl_NYCTaxicab
#' @export

etl_load.etl_NYCTaxicab <- function(obj, script = FALSE, years = 2015, months = 1:12, ...) {
  csvs <- match_files_by_year_months(list.files(attr(obj, "load_dir")), 
                                     pattern = "flights_%Y_%m.csv", years, months)
  sapply(paste0(attr(obj, "load_dir"), "/", csvs), push_month, obj = obj, ...)
  invisible(obj)
}