tests/testthat/helper_read_parquet.R

In armbrustlab/popcycle: Popcycle: An R package providing reproducible analytical methods to uniformly process and curate SeaFlow data

make_small_vct <- function() {
  df <- tibble::tibble(
    date = c(rep("date1", 3), rep("date2", 3)),
    D1 = seq(6),
    D2 = seq(6) + 1,
    fsc_small = seq(6) * 2,
    q2.5 = c(TRUE, TRUE, TRUE, TRUE, TRUE, TRUE),
    q50 = c(TRUE, TRUE, FALSE, FALSE, TRUE, TRUE),
    diam_lwr_q2.5 = seq(6),
    diam_mid_q2.5 = seq(6) + 1,
    diam_upr_q2.5 = seq(6) + 2,
    diam_lwr_q50 = seq(6) + 3,
    diam_mid_q50 = seq(6) + 4,
    diam_upr_q50 = seq(6) + 5,
    Qc_lwr_q2.5 = seq(6) + 6,
    Qc_mid_q2.5 = seq(6) + 7,
    Qc_upr_q2.5 = seq(6) + 8,
    Qc_lwr_q50 = seq(6) + 9,
    Qc_mid_q50 = seq(6) + 10,
    Qc_upr_q50 = seq(6) + 11,
    pop_q2.5 = c("a", "a", "b", "b", "c", "c"),
    pop_q50 = c("a", "a", "b", "b", "b", "c"),
  )
  # Get _q2.5 column names, set !q2.5 values to NA
  q2.5_cols <- names(df)[endsWith(names(df), "_q2.5")]
  df[!df$q2.5, q2.5_cols] <- NA
  # Get _q50 column names, set !q50 values to NA
  q50_cols <- names(df)[endsWith(names(df), "_q50")]
  df[!df$q50, q50_cols] <- NA

  return(df)
}

make_range_vct <- function(tempdir) {
  df <- tibble::tibble(
    date = c(
      rep("date1", 3), rep("date2", 3),
      rep("date3", 3), rep("date4", 3)
    ),
    pe = c(
      1, 2, 3, 4, 5, 6,
      3, 4, 5, 6, 7, 8
    ),
    q2.5 = c(
      FALSE, TRUE, TRUE, TRUE, TRUE, TRUE,
      TRUE, TRUE, TRUE, TRUE, TRUE, FALSE
    ),
    diam_lwr_q2.5 = seq(12),
    diam_mid_q2.5 = seq(12) + 1,
    diam_upr_q2.5 = seq(12) + 2,
    pop_q2.5 = c(
      "a", "a", "b", "b", "c", "c",
      "a", "a", "b", "b", "c", "c"
    ),
  )
  # Get _q2.5 column names, set !q2.5 values to NA
  q2.5_cols <- names(df)[endsWith(names(df), "_q2.5")]
  df[!df$q2.5, q2.5_cols] <- NA

  arrow::write_parquet(df %>% dplyr::filter(date %in% c("date1", "date2")), file.path(tempdir, "1.parquet"))
  arrow::write_parquet(df %>% dplyr::filter(date %in% c("date3", "date4")), file.path(tempdir, "2.parquet"))

  return(df)
}