scattermethod  R Documentation 
This method lets a rank scatter objects to every rank in the same communicator. The default input is a list of length equal to ‘comm size’ and the default return is an element of the list.
scatter(x, x.buffer = NULL, x.count = NULL, displs = NULL,
rank.source = .pbd_env$SPMD.CT$rank.source,
comm = .pbd_env$SPMD.CT$comm)
x 
an object of length ‘comm size’ to be scattered to all ranks. 
x.buffer 
a buffer to hold the return object which probably has
'size of element of 
x.count 
a vector of length ‘comm size’ containing all object lengths. 
displs 

rank.source 
a rank of source where elements of 
comm 
a communicator number. 
All elements of x
are likely presumed to have the same size and type.
x.buffer
, x.count
, and displs
can be NULL
or
unspecified. If specified, the type should be one of integer, double, or
raw specified correctly according to the type of x
.
If x.count
is specified, then the spmd.scatterv.*()
is
called.
An element of x
is returned according to the rank id.
For calling spmd.scatter.*()
:
signature(x = "ANY", x.buffer = "missing", x.count = "missing")
signature(x = "integer", x.buffer = "integer", x.count = "missing")
signature(x = "numeric", x.buffer = "numeric", x.count = "missing")
signature(x = "raw", x.buffer = "raw", x.count = "missing")
For calling spmd.scatterv.*()
:
signature(x = "ANY", x.buffer = "missing", x.count = "integer")
signature(x = "ANY", x.buffer = "ANY", x.count = "integer")
signature(x = "integer", x.buffer = "integer", x.count = "integer")
signature(x = "numeric", x.buffer = "numeric", x.count = "integer")
signature(x = "raw", x.buffer = "raw", x.count = "integer")
WeiChen Chen wccsnow@gmail.com, George Ostrouchov, Drew Schmidt, Pragneshkumar Patel, and Hao Yu.
Programming with Big Data in R Website: https://pbdr.org/
bcast()
.
### Save code in a file "demo.r" and run with 2 processors by
### SHELL> mpiexec np 2 Rscript demo.r
spmd.code < "
### Initialize
suppressMessages(library(pbdMPI, quietly = TRUE))
.comm.size < comm.size()
.comm.rank < comm.rank()
### Examples.
N < 5
x < split(1:(N * .comm.size), rep(1:.comm.size, N))
y < scatter(lapply(x, matrix, nrow = 1))
comm.print(y)
y < scatter(x, double(N))
comm.print(y)
### Finish.
finalize()
"
pbdMPI::execmpi(spmd.code, nranks = 2L)
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.