|
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 Message Passing Interface (MPI) Cluster of R Workers for Parallel Processing |
|
checkNumberOfLocalWorkers() makeClusterPSOCK() makeNodePSOCK()
|
Create a 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 |