rrqlapply: Parallel version of lapply using Redis queuing

In traitecoevo/rrqueue: Scalable Job Queues for R with 'Redis'

Description

Parallel version of lapply using Redis queuing

Usage

rrqlapply(X, FUN, rrq, ..., group = NULL, timeout = Inf, time_poll = 1,
  delete_tasks = FALSE, progress_bar = TRUE, env = parent.frame())

rrqlapply_submit(X, FUN, rrq, ..., group = NULL, progress_bar = TRUE,
  env = parent.frame())

Arguments

X	A vector
FUN	The name of a function to apply to each element of the list. this will change!.
rrq	An rrq object
...	Additional arguments passed to FUN
group	Name of a group for generated task ids. If not included, an ID will be generated.
timeout	Total length of time to wait for tasks to be completed. The default is to wait forever (like lapply).
time_poll	Time to poll for tasks. Must be an integer. Because of how the function is implemented, R will be unresponsive for this long each iteration (unless results are returned), so the default of 1s should be reasonable.
delete_tasks	Delete tasks on successful finish?
progress_bar	Display a progress bar?
env	Environment to look in.

traitecoevo/rrqueue documentation built on May 31, 2019, 7:44 p.m.