Package index

All functions

as.cluster() c(<cluster>)

Coerce an Object to a Cluster Object

autoStopCluster()

Automatically Stop a Cluster when Garbage Collected

availableConnections() freeConnections()

Number of Available and Free Connections

availableCores()

Get Number of Available Cores on The Current Machine

availableWorkers()

Get Set of Available Workers

cloneNode()

Clone one or more nodes

freePort()

Find a TCP port that can be opened

isConnectionValid() connectionId()

Checks if a Connection is Valid

isForkedChild()

Checks whether or not we are running in a forked child process

isForkedNode()

Checks whether or not a Cluster Node Runs in a Forked Process

isLocalhostNode()

Checks whether or not a Cluster Node Runs on Localhost

isNodeAlive()

Check whether or not the cluster nodes are alive

killNode()

Terminate one or more cluster nodes using process signaling

makeClusterMPI()

Create a Rich Message Passing Interface (MPI) Cluster of R Workers for Parallel Processing

makeClusterPSOCK() makeNodePSOCK()

Create a Rich PSOCK Cluster of R Workers for Parallel Processing

makeClusterSequential()

Create a "parallel" cluster running sequentially in the current session

parallelly.options parallelly.debug parallelly.availableCores.custom parallelly.availableCores.methods parallelly.availableCores.min parallelly.availableCores.fallback parallelly.availableCores.omit parallelly.availableCores.system parallelly.availableWorkers.methods parallelly.availableWorkers.custom parallelly.fork.enable parallelly.maxWorkers.localhost parallelly.supportsMulticore.disableOn parallelly.supportsMulticore.unstable R_PARALLELLY_AVAILABLECORES_FALLBACK R_PARALLELLY_AVAILABLECORES_OMIT R_PARALLELLY_AVAILABLECORES_SYSTEM R_PARALLELLY_AVAILABLECORES_MIN R_PARALLELLY_FORK_ENABLE R_PARALLELLY_SUPPORTSMULTICORE_DISABLEON R_PARALLELLY_SUPPORTSMULTICORE_UNSTABLE future.availableCores.custom future.availableCores.methods future.availableCores.fallback future.availableCores.system future.availableWorkers.methods future.availableWorkers.custom future.fork.enable future.supportsMulticore.unstable R_FUTURE_AVAILABLECORES_FALLBACK R_FUTURE_AVAILABLECORES_SYSTEM R_FUTURE_FORK_ENABLE R_FUTURE_SUPPORTSMULTICORE_UNSTABLE parallelly.makeNodePSOCK.setup_strategy parallelly.makeNodePSOCK.validate parallelly.makeNodePSOCK.connectTimeout parallelly.makeNodePSOCK.timeout parallelly.makeNodePSOCK.useXDR parallelly.makeNodePSOCK.socketOptions parallelly.makeNodePSOCK.rshcmd parallelly.makeNodePSOCK.rshopts parallelly.makeNodePSOCK.tries parallelly.makeNodePSOCK.tries.delay R_PARALLELLY_MAKENODEPSOCK_SETUP_STRATEGY R_PARALLELLY_MAKENODEPSOCK_VALIDATE R_PARALLELLY_MAKENODEPSOCK_CONNECTTIMEOUT R_PARALLELLY_MAKENODEPSOCK_TIMEOUT R_PARALLELLY_MAKENODEPSOCK_USEXDR R_PARALLELLY_MAKENODEPSOCK_SOCKETOPTIONS R_PARALLELLY_MAKENODEPSOCK_RSHCMD R_PARALLELLY_MAKENODEPSOCK_RSHOPTS R_PARALLELLY_MAKENODEPSOCK_TRIES R_PARALLELLY_MAKENODEPSOCK_TRIES_DELAY

Options Used by the 'parallelly' Package

serializedSize()

Calculate the size of an R object when it is serialized

supportsMulticore()

Check If Forked Processing ("multicore") is Supported