# Set number of data.table threads to 2 data.table::setDTthreads(threads = 2L) # Set number of collapse threads to 1 collapse::set_collapse(nthreads = 1L) testthat::test_that("edf", { set.seed(819384556) x <- sample(seq(-10, 10, 0.5), size = 10^5, replace = TRUE) testthat::expect_equal(edf(x), stats::ecdf(x)(x)) testthat::expect_equal(edf(x), dplyr::cume_dist(x)) g <- sample(letters[1:5], size = 10^5, replace = TRUE) edf1 <- dplyr::tibble(x, g) %>% dplyr::mutate(edf = dplyr::cume_dist(x), .by = g) %>% dplyr::pull(edf) edf2 <- edf(x, g = g) testthat::expect_equal(edf1, edf2) # With weights df1 <- dplyr::tibble(x) %>% dplyr::mutate(edf1 = edf(x)) %>% fastplyr::f_count(x, edf1) %>% dplyr::slice_sample(n = df_nrow(.)) %>% dplyr::mutate(edf2 = edf(x, wt = n)) testthat::expect_equal(df1$edf1, df1$edf2) df2 <- dplyr::tibble(x, g) %>% dplyr::mutate(edf1 = edf(x, g = g)) %>% fastplyr::f_count(x, g, edf1) %>% dplyr::slice_sample(n = df_nrow(.)) %>% dplyr::mutate(edf2 = edf(x, wt = n, g = g)) testthat::expect_equal(df2$edf1, df2$edf2) x[sample(seq_len(length(x)), size = 10^3)] <- NA testthat::expect_equal(edf(x), stats::ecdf(x)(x)) testthat::expect_equal(edf(x), dplyr::cume_dist(x)) edf1 <- dplyr::tibble(x, g) %>% dplyr::mutate(edf = dplyr::cume_dist(x), .by = g) %>% dplyr::pull(edf) edf2 <- edf(x, g = g) testthat::expect_equal(edf1, edf2) # With weights df3 <- dplyr::tibble(x) %>% dplyr::mutate(edf1 = edf(x)) %>% fastplyr::f_count(x, edf1) %>% dplyr::slice_sample(n = df_nrow(.)) %>% dplyr::mutate(edf2 = edf(x, wt = n)) testthat::expect_equal(df3$edf1, df3$edf2) df4 <- dplyr::tibble(x, g) %>% dplyr::mutate(edf1 = edf(x, g = g)) %>% fastplyr::f_count(x, g, edf1) %>% dplyr::slice_sample(n = df_nrow(.)) %>% dplyr::mutate(edf2 = edf(x, wt = n, g = g)) testthat::expect_equal(df4$edf1, df4$edf2) testthat::expect_equal(edf(x, g = g, wt = 1), edf(x, g = g)) testthat::expect_equal(edf(x, wt = 1), edf(x)) testthat::expect_error(edf(x, wt = 1:3)) })