R/future-map.R
future_map_if.Rd
These functions work exactly the same as purrr::map_if()
and
purrr::map_at()
, but allow you to run them in parallel.
future_map_if( .x, .p, .f, ..., .else = NULL, .options = furrr_options(), .env_globals = parent.frame(), .progress = FALSE ) future_map_at( .x, .at, .f, ..., .options = furrr_options(), .env_globals = parent.frame(), .progress = FALSE )
.x | A list or atomic vector. |
---|---|
.p | A single predicate function, a formula describing such a
predicate function, or a logical vector of the same length as |
.f | A function, formula, or vector (not necessarily atomic). If a function, it is used as is. If a formula, e.g.
This syntax allows you to create very compact anonymous functions. If character vector, numeric vector, or list, it is
converted to an extractor function. Character vectors index by
name and numeric vectors index by position; use a list to index
by position and name at different levels. If a component is not
present, the value of |
... | Additional arguments passed on to the mapped function. |
.else | A function applied to elements of |
.options | The |
.env_globals | The environment to look for globals required by |
.progress | A single logical. Should a progress bar be displayed? Only works with multisession, multicore, and multiprocess futures. Note that if a multicore/multisession future falls back to sequential, then a progress bar will not be displayed. Warning: The |
.at | A character vector of names, positive numeric vector of
positions to include, or a negative numeric vector of positions to
exlude. Only those elements corresponding to |
Both functions return a list the same length as .x
with the
elements conditionally transformed.
plan(multisession, workers = 2) # Modify the even elements future_map_if(1:5, ~.x %% 2 == 0L, ~ -1)#> [[1]] #> [1] 1 #> #> [[2]] #> [1] -1 #> #> [[3]] #> [1] 3 #> #> [[4]] #> [1] -1 #> #> [[5]] #> [1] 5 #>#> [[1]] #> [1] -1 #> #> [[2]] #> [1] 2 #> #> [[3]] #> [1] 3 #> #> [[4]] #> [1] 4 #> #> [[5]] #> [1] -1 #># \dontshow{ # Close open connections for R CMD Check if (!inherits(plan(), "sequential")) plan(sequential) # }