R/combine_monthly_links_subfun.R

In lhenneman/disperseR: Run HYSPLIT many times in parallel, aggregate to zip code level, plot the results, save the plots.

#' @export read_ziplinks_subfun
read_ziplinks_subfun <- function(i, files) {
  d <- read.fst(files[i], as.data.table = TRUE)
  d[, `:=` (ZIP = as(ZIP, 'character'),
            month = as(month, 'character'))]
  d <- d[N > 0]
  return(d)
}

#' @export read_gridlinks_subfun
read_gridlinks_subfun <- function(i, files) {
  d <- read.fst(files[i], as.data.table = TRUE)
  d[, month := as( month, 'character')]
  d <- d[N > 0]
  return(d)
}

#' @export read_countylinks_subfun
read_countylinks_subfun <- function(i, files) {
  d <- read.fst(files[i], as.data.table = TRUE)
  d[, month := as( month, 'character')]
  d <- d[ N > 0]
  return(d)
}