A lightweight and intuitive framework for building interactive data analysis pipelines. You add R functions one by one, and pipeflow wires them into a pipeline that stays consistent as you go. Modify,
DataR · HTMLGitHub @rpahlOnlineOwner unconfirmed
Have you tried it? One tap is enough. No sign-in needed.
Loading comments.
Checking sign-in status.
An R package to build fast interactive data analysis pipelines that scale.
Taken from the repository README
Loading the full README.
Read the full README ↗{pipeflow} is a lightweight framework for building interactive data analysis pipelines in R. You add R functions one by one as steps, tell {pipeflow} which steps they take their inputs from, and it keeps the pipeline consistent as you insert, replace or remove steps.
# Install release version from CRAN
install.packages("pipeflow")
# Install development version from GitHub
devtools::install_github("rpahl/pipeflow")
library(pipeflow)
p <- pip_new("demo") |>
pip_add("numbers", \(n = 5) seq_len(n)) |>
pip_add("squared", \(x = ~numbers) x^2) |>
pip_add("total", \(x = ~squared) sum(x))
p
# <pipeflow> demo (3 steps)
# -------------------------
# step params depends state
# 1: numbers n new
# 2: squared x numbers new
# 3: total x squared new
# -------------------------
# <ready> last run: never
pip_run(p)
# info [2026-10-25 16:44:38.543 UTC]: Starting run of pipeflow 'demo'
# info [2026-10-25 16:44:38.543 UTC]: Step 1/3 numbers
# info [2026-10-25 16:44:38.549 UTC]: Step 2/3 squared
# info [2026-10-25 16:44:38.553 UTC]: Step 3/3 total
# info [2026-10-25 16:44:38.554 UTC]: Finished in 0.012 s (3 done, 0 skipped, 0 failed)
pip_collect(p)
# $numbers
# [1] 1 2 3 4 5
#
# $squared
# [1] 1 4 9 16 25
#
# $total
# [1] 55
It is recommended to read the vignettes in the order they are listed below: