functionals: Functional programming with parallelism and progress track in R

Description

This package provides a consistent and intuitive API for applying functions over lists, vectors, and data frames, with built-in support for parallelism and progress bars.

Author(s)

Maintainer: Imad EL BADISY elbadisyimad@gmail.com

See Also

Useful links:

• Report bugs at https://github.com/ielbadisy/functionals/issues

Apply a function over a list or vector with optional parallelism and progress

Description

A lightweight and fast version of 'lapply()' with support for multicore (Unix) and snow-style clusters via 'parallel', with internal progress bar tracking and message suppression.

Usage

fapply(.x, .f, ncores = 1, pb = FALSE, cl = NULL, load_balancing = TRUE, ...)

Arguments

Value

A list of results.

Examples

# Basic usage (sequential)
fapply(1:5, sqrt)
# With progress bar (sequential)
fapply(1:5, function(x) { Sys.sleep(0.1); x^2 }, pb = TRUE)
# Multicore on Unix (if available)
if (.Platform$OS.type != "windows") {
 fapply(1:10, sqrt, ncores = 2)
}
# With user-created cluster (portable across platforms)
cl <- parallel::makeCluster(2)
fapply(1:10, sqrt, cl = cl)
parallel::stopCluster(cl)
# Heavy computation example with chunked parallelism
heavy_fn <- function(x) { Sys.sleep(0.05); x^2 }
fapply(1:20, heavy_fn, ncores = 2, pb = TRUE)

Compose multiple functions

Description

Create a new function by composing several functions, applied from right to left. Equivalent to 'f1(f2(f3(...)))'.

Usage

fcompose(...)

Arguments

Value

A new function equivalent to nested application of the input functions.

Examples

square <- function(x) x^2
add1 <- function(x) x + 1
f <- fcompose(sqrt, square, add1) # => sqrt(square(x + 1))
f(4) # => sqrt((4 + 1)^2) = sqrt(25) = 5
# More compact
fcompose(log, exp)(2) # log(exp(2)) = 2

Functional Cross-Validation mapping

Description

Applies a user-defined function '.f' to each element of '.splits', typically from cross-validation objects such as 'rsample::vfold_cv()'.

Usage

fcv(.splits, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results returned by applying '.f' to each element of '.splits'.

Examples

if (requireNamespace("rsample", quietly = TRUE)) {
 set.seed(123)
 cv_splits <- rsample::vfold_cv(mtcars, v = 5)
 # Apply summary over training sets
 fcv(cv_splits$splits, function(split) {
 summary(rsample::analysis(split))
 })
 # With progress and parallel execution
 
 fcv(cv_splits$splits, function(split) {
 summary(rsample::analysis(split))
 }, ncores = 2, pb = TRUE)
 
}

Functional loop with optional parallelism and progress bar

Description

'floop()' applies a function '.f' to each element of '.x', optionally in parallel, and with an optional progress bar. Unlike 'fwalk()', it can return results or be used purely for side effects (like a for-loop).

Usage

floop(.x, .f, ncores = 1, pb = FALSE, .capture = TRUE, ...)

Arguments

Value

A list of results if '.capture = TRUE', otherwise returns '.x' invisibly.

Examples

# Functional loop that collects output
floop(1:3, function(i) i^2)
# Side-effect only loop (like for-loop with cat)
floop(1:5, function(i) cat(" Processing", i, "\n"), pb = TRUE, .capture = FALSE)

Functional mapping with optional parallelism and progress bars

Description

Applies a function '.f' to each element of '.x', with optional parallel processing and progress bar support.

Usage

fmap(.x, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results, one for each element of '.x'.

Examples

slow_fn <- function(x) { Sys.sleep(0.01); x^2 }
x <- 1:100
# Basic usage
fmap(x, slow_fn)
# With progress bar
fmap(x, slow_fn, pb = TRUE)
# With parallel execution (non-Windows)
if (.Platform$OS.type != "windows") {
 fmap(x, slow_fn, ncores = 2, pb = TRUE)
}

Apply a function column-wise with name access and parallelism

Description

Applies a function '.f' to each column of a data frame '.df'. Each call receives both the column vector and its name, enabling name-aware column processing. Supports parallel execution and progress display.

Usage

fmapc(.df, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results obtained by applying '.f' to each column of '.df'.

Examples

df <- data.frame(a = 1:3, b = 4:6)
# Apply a function that returns column mean and name
fmapc(df, function(x, name) list(mean = mean(x), var = var(x), name = name))
# With progress and parallel execution
fmapc(df, function(x, name) mean(x), ncores = 2, pb = TRUE)

Apply a function to groups of a data frame in parallel

Description

Applies a function '.f' to each group of rows in a data frame '.df', where grouping is defined by one or more variables in 'by'. Each group is passed as a data frame to '.f'. Supports parallelism and optional progress display.

Usage

fmapg(.df, .f, by, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results, one for each group defined by 'by'.

Examples

# Group-wise mean of Sepal.Length in iris dataset
fmapg(iris, function(df) mean(df$Sepal.Length), by = "Species")
# Group-wise model fitting with progress and parallelism
fmapg(mtcars, function(df) lm(mpg ~ wt, data = df), by = "cyl", ncores = 2, pb = TRUE)

Apply a function over multiple argument lists in parallel

Description

Applies a function '.f' over multiple aligned lists in '.l'. Each element of '.l' should be a list or vector of the same length. Each call to '.f' receives one element from each list. Supports parallel execution and progress display.

Usage

fmapn(.l, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results obtained by applying '.f' to each tuple from '.l'.

Examples

# Fit a linear model for each response variable using the same predictor
df <- data.frame(
 y1 = rnorm(100),
 y2 = rnorm(100),
 x = rnorm(100)
)
# List of formulas and data
formulas <- list(y1 ~ x, y2 ~ x)
data_list <- list(df, df)
fmapn(list(formula = formulas, data = data_list), function(formula, data) {
 lm(formula, data = data)
})
# Extract model summaries in parallel
models <- fmapn(list(formula = formulas, data = data_list), function(formula, data) {
 summary(lm(formula, data = data))$r.squared
})

Apply a function row-wise on a data frame with parallelism

Description

Applies a function '.f' to each row of a data frame '.df', with optional parallelism and progress bar. Each row is converted to a named list before being passed to '.f', enabling flexible access to variables by name.

Usage

fmapr(.df, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

A list of results returned by applying '.f' to each row as a list.

Examples

df <- data.frame(name = c("Mister", "Hipster"), age = c(30, 25))
# Create personalized messages
fmapr(df, function(row) paste(row$name, "is", row$age, "years old"))
# Row-wise model formulas
formulas <- data.frame(
 response = c("y1", "y2"),
 predictor = c("x1", "x2"),
 stringsAsFactors = FALSE
)
fmapr(formulas, function(row) {
 reformulate(row$predictor, row$response)
})

Functional reduce

Description

Apply a binary function iteratively over a list or vector, reducing it to a single value or a sequence of intermediate results. This is a wrapper around [Reduce()] that supports optional initial values, right-to-left evaluation, accumulation of intermediate steps, and output simplification.

Usage

freduce(
 .x,
 .f,
 .init = NULL,
 .right = FALSE,
 .accumulate = FALSE,
 .simplify = TRUE
)

Arguments

Value

A single value (default) or a list/vector of intermediate results if '.accumulate = TRUE'.

Examples

freduce(1:5, `+`) # => 15
freduce(letters[1:4], paste0) # => "abcd"
freduce(list(1, 2, 3), `*`) # => 6
freduce(1:3, `+`, .init = 10) # => 16
freduce(1:3, paste0, .right = TRUE) # => "321"
freduce(1:4, `+`, .accumulate = TRUE) # => c(1, 3, 6, 10)

Repeat an expression or function call multiple times

Description

Repeats an expression or function evaluation 'times' times. If 'expr' is a function, it is invoked with optional input '.x' and additional arguments. If 'expr' is a quoted expression, it is evaluated in the parent environment. Supports parallel processing and optional simplification of results.

Usage

frepeat(
 .x = NULL,
 times,
 expr,
 simplify = FALSE,
 ncores = NULL,
 pb = FALSE,
 ...
)

Arguments

Value

A list of outputs (or a simplified array if 'simplify = TRUE') from evaluating 'expr' multiple times.

Note

If 'expr' is passed as a function call (not a function or quoted expression), it will be evaluated immediately, not repeated. Use function(...) \{ ... \} or quote(...) instead.

Examples

# Repeat a pure function call
frepeat(times = 3, expr = function() rnorm(1))
# Repeat a function with input `.x`
frepeat(.x = 10, times = 3, expr = function(x) rnorm(1, mean = x))
# Repeat an unevaluated expression (evaluated with `eval()`)
frepeat(times = 2, expr = quote(rnorm(1)))
# Simplify the output to an array
frepeat(times = 3, expr = function() rnorm(1), simplify = TRUE)
# Monte Carlo simulation: estimate coverage of a 95% CI for sample mean
mc_result <- frepeat(times = 1000, simplify = TRUE, pb = TRUE, ncores = 1, expr = function() {
 sample <- rnorm(30, mean = 0, sd = 1)
 ci <- t.test(sample)$conf.int
 mean(ci[1] <= 0 & 0 <= ci[2]) # check if true mean is inside the interval
})
mean(mc_result) # estimated coverage

Walk over a vector or list with side effects

Description

Applies a function '.f' to each element of '.x', typically for its side effects (e.g., printing, writing files). This function is the side-effect-friendly equivalent of 'fmap()'. Supports parallel execution and progress bar display.

Usage

fwalk(.x, .f, ncores = NULL, pb = FALSE, ...)

Arguments

Value

Invisibly returns '.x', like 'purrr::walk()'.

Examples

# Print each element
fwalk(1:3, print)
# Simulate writing files in parallel
fwalk(1:3, function(i) {
 cat(paste("Processing item", i, "\n"))
 Sys.sleep(0.5)
}, ncores = 2, pb = TRUE)