pbdMPI (version 0.2-2)

global any and all functions: Global Any and All Functions

Description

These functions are global any and all applying on distributed data for all ranks.

Usage

comm.any(x, na.rm = FALSE, comm = .SPMD.CT$comm)
  comm.all(x, na.rm = FALSE, comm = .SPMD.CT$comm)

Arguments

x

a vector.

na.rm

if NA removed or not.

comm

a communicator number.

Value

• The global check values (TRUE, FALSE, NA) are returned to all ranks.

Details

These functions will apply any() and all() locally, and apply allgather to get all local results from other ranks, then apply any() and all() on all local results.

References

Programming with Big Data in R Website: http://r-pbd.org/

Examples

# Save code in a file "demo.r" and run with 2 processors by
# > mpiexec -np 2 Rscript demo.r

### Initial
library(pbdMPI, quietly = TRUE)
init()
if(comm.size() != 2){
  comm.cat("2 processors are requried.\n", quiet = TRUE)
  finalize()
}

### Examples
if(comm.rank() == 0){
  a <- c(T, F, NA)
} else{
  a <- T
}

comm.print(comm.any(a))
comm.print(comm.all(a))
comm.print(comm.any(a, na.rm = TRUE))
comm.print(comm.all(a, na.rm = TRUE))

### Finish
finalize()