pbdMPI: Programming with Big Data -- Interface to MPI

Share:

An efficient interface to MPI by utilizing S4 classes and methods with a focus on Single Program/Multiple Data ('SPMD') parallel programming style, which is intended for batch parallel execution.

Author
Wei-Chen Chen [aut, cre], George Ostrouchov [aut], Drew Schmidt [aut], Pragneshkumar Patel [aut], Hao Yu [aut], Christian Heckendorf [ctb] (FreeBSD), Brian Ripley [ctb] (Windows HPC Pack 2012), R Core team [ctb] (some functions are modified from the base packages)
Date of publication
2016-07-15 10:31:37
Maintainer
Wei-Chen Chen <wccsnow@gmail.com>
License
Mozilla Public License 2.0
Version
0.3-2
URLs

View on CRAN

Man pages

00_pbdMPI-package
Programming with Big Data - Interface to MPI
11_d_control
Sets of controls in pbdMPI.
11_d_pbd_opt
Set Global pbdR Options
aa_allgather-method
All Ranks Gather Objects from Every Rank
aa_allreduce-method
All Ranks Receive a Reduction of Objects from Every Rank
aa_bcast-method
A Rank Broadcast an Object to Every Rank
aa_gather-method
A Rank Gathers Objects from Every Rank
aa_reduce-method
A Rank Receive a Reduction of Objects from Every Rank
aa_scatter-method
A Rank Scatter Objects to Every Rank
ab_recv-method
A Rank Receives (Blocking) an Object from the Other Rank
ab_send-method
A Rank Send (blocking) an Object to the Other Rank
ac_irecv-method
A Rank Receives (Nonblocking) an Object from the Other Rank
ac_isend-method
A Rank Send (Nonblocking) an Object to the Other Rank
ad_sendrecv-method
Send and Receive an Object to and from Other Ranks
ad_sendrecv.replace-method
Send and Receive an Object to and from Other Ranks
ae_alltoall
All to All
cc_arrange.mpi.apts
Set or Get MPI Array Pointers in R
cc_comm
Communicator Functions
dd_info
Info Functions
dd_is.comm.null
Check if a MPI_COMM_NULL
dd_prob
Probe Functions
dd_sourcetag
Functions to Obtain source and tag
dd_wait
Wait Functions
vv_get_jid
Divide Job ID by Ranks
vv_print_cat
Global Print and Cat Functions
vv_seed
Seed Functions for Random Number Generators
ww_comm_as_gbd
Global As GBD Function
ww_comm_balance
Global Balance Functions
ww_comm_read
Global Reading Functions
ww_comm_write
Global Writing Functions
xx_comm_allpairs
Global All Pairs
xx_comm_any_all
Global Any and All Functions
xx_comm_base
Global Base Functions
xx_comm_dist
Global Distance for Distributed Matrices
xx_comm_match_arg
Global Argument Matching
xx_comm_pairwise
Global Pairwise Evaluations
xx_comm_range
Global Range, Max, and Min Functions
xx_comm_Rprof
A Rprof Function for SPMD Routines
xx_comm_sort
Global Quick Sort for Distributed Vectors or Matrices
xx_comm_stop_warning
Global Stop and Warning Functions
xx_comm_timer
A Timing Function for SPMD Routines
xx_comm_which
Global Which Functions
yy_api_apply
Parallel Apply and Lapply Functions
yy_api_task_pull
Functions for Task Pull Parallelism
zz_comm_internal
All Comm Internal Functions
zz_spmd_control
Sets of controls in pbdMPI.
zz_spmd_internal
All SPMD Internal Functions

Files in this package

pbdMPI
pbdMPI/COPYING
pbdMPI/inst
pbdMPI/inst/examples
pbdMPI/inst/examples/test_performance
pbdMPI/inst/examples/test_performance/demo_scatter_rmpi.r
pbdMPI/inst/examples/test_performance/demo_allgather_rmpi.r
pbdMPI/inst/examples/test_performance/00_test_all.sh
pbdMPI/inst/examples/test_performance/demo_allgather_spmd.r
pbdMPI/inst/examples/test_performance/00_test_all.win
pbdMPI/inst/examples/test_performance/demo_scatter_spmd.r
pbdMPI/inst/examples/test_rmpi
pbdMPI/inst/examples/test_rmpi/sendrecv_rmpi.r
pbdMPI/inst/examples/test_rmpi/allreduce_spmd.r
pbdMPI/inst/examples/test_rmpi/gather_rmpi.r
pbdMPI/inst/examples/test_rmpi/gather_spmd.r
pbdMPI/inst/examples/test_rmpi/allgather_spmd.r
pbdMPI/inst/examples/test_rmpi/allgatherv_rmpi.r
pbdMPI/inst/examples/test_rmpi/00_test_spmd.win
pbdMPI/inst/examples/test_rmpi/scatter_spmd.r
pbdMPI/inst/examples/test_rmpi/scatterv_rmpi.r
pbdMPI/inst/examples/test_rmpi/allreduce_rmpi.r
pbdMPI/inst/examples/test_rmpi/scatter_rmpi.r
pbdMPI/inst/examples/test_rmpi/bcast_spmd.r
pbdMPI/inst/examples/test_rmpi/00_test_all.sh
pbdMPI/inst/examples/test_rmpi/allgatherv_spmd.r
pbdMPI/inst/examples/test_rmpi/reduce_rmpi.r
pbdMPI/inst/examples/test_rmpi/01_setting
pbdMPI/inst/examples/test_rmpi/scatterv_spmd.r
pbdMPI/inst/examples/test_rmpi/reduce_spmd.r
pbdMPI/inst/examples/test_rmpi/bcast_rmpi.r
pbdMPI/inst/examples/test_rmpi/sendrecv_spmd.r
pbdMPI/inst/examples/test_rmpi/allgather_rmpi.r
pbdMPI/inst/examples/test_s4
pbdMPI/inst/examples/test_s4/01_simple.r
pbdMPI/inst/examples/test_s4/02_mean.r
pbdMPI/inst/examples/test_s4/00_test_all.sh
pbdMPI/inst/examples/test_s4/00_test_all.win
pbdMPI/inst/examples/README
pbdMPI/inst/examples/test_long_vector
pbdMPI/inst/examples/test_long_vector/allgather.r
pbdMPI/inst/examples/test_long_vector/allreduce.r
pbdMPI/inst/examples/test_long_vector/bcast.r
pbdMPI/inst/examples/test_long_vector/scatter.r
pbdMPI/inst/examples/test_long_vector/send_recv.r
pbdMPI/inst/examples/test_long_vector/reduce.r
pbdMPI/inst/examples/test_long_vector/00_test_all.sh
pbdMPI/inst/examples/test_long_vector/00_test_all.win
pbdMPI/inst/examples/test_long_vector/gather.r
pbdMPI/inst/examples/test_spmd
pbdMPI/inst/examples/test_spmd/sendrecv.r
pbdMPI/inst/examples/test_spmd/sendrecv_replace.r
pbdMPI/inst/examples/test_spmd/allgather.r
pbdMPI/inst/examples/test_spmd/allreduce.r
pbdMPI/inst/examples/test_spmd/isend_irecv_wait.r
pbdMPI/inst/examples/test_spmd/bcast.r
pbdMPI/inst/examples/test_spmd/scatter.r
pbdMPI/inst/examples/test_spmd/send_recv.r
pbdMPI/inst/examples/test_spmd/reduce.r
pbdMPI/inst/examples/test_spmd/00_test_all.sh
pbdMPI/inst/examples/test_spmd/00_test_all.win
pbdMPI/inst/examples/test_spmd/gather.r
pbdMPI/inst/examples/test_spmd/replace.r
pbdMPI/inst/examples/test_parallel
pbdMPI/inst/examples/test_parallel/01_mclapply_par.r
pbdMPI/inst/examples/test_parallel/00_test_all.sh
pbdMPI/inst/examples/test_parallel/03_boot_par.r
pbdMPI/inst/examples/test_parallel/02_parMM_par.r
pbdMPI/inst/examples/test_parallel/00_test_all.win
pbdMPI/inst/examples/test_parallel/01_mclapply_spmd.r
pbdMPI/inst/examples/test_parallel/03_boot_spmd.r
pbdMPI/inst/examples/test_parallel/02_parMM_spmd.r
pbdMPI/inst/examples/test_parallel/04_glm_par.r
pbdMPI/inst/examples/test_parallel/04_glm_spmd.r
pbdMPI/inst/examples/test_cs
pbdMPI/inst/examples/test_cs/named.server.r
pbdMPI/inst/examples/test_cs/simple.server.r
pbdMPI/inst/examples/test_cs/README
pbdMPI/inst/examples/test_cs/named.client.r
pbdMPI/inst/examples/test_cs/simple.client.r
pbdMPI/inst/CITATION
pbdMPI/inst/tests
pbdMPI/inst/tests/allgather.r
pbdMPI/inst/tests/allreduce.r
pbdMPI/inst/tests/bcast.r
pbdMPI/inst/tests/reduce.r
pbdMPI/inst/tests/gather.r
pbdMPI/inst/tests/barrier.r
pbdMPI/inst/doc
pbdMPI/inst/doc/pbdMPI-guide.pdf
pbdMPI/inst/doc/pbdMPI-guide.Rnw
pbdMPI/configure.ac
pbdMPI/src
pbdMPI/src/spmd_tool.c
pbdMPI/src/pkg_tools.c
pbdMPI/src/spmd_bcast.c
pbdMPI/src/install.libs.R
pbdMPI/src/spmd_wait.c
pbdMPI/src/spmd_alltoall.c
pbdMPI/src/spmd_recv.c
pbdMPI/src/comm_sort_double.c
pbdMPI/src/spmd_utility.c
pbdMPI/src/comm_sort_integer.c
pbdMPI/src/spmd_gather.c
pbdMPI/src/spmd_allgather.c
pbdMPI/src/zzz.c
pbdMPI/src/spmd_scatter.c
pbdMPI/src/comm_errors.c
pbdMPI/src/spmd_sendrecv_replace.c
pbdMPI/src/spmd.h
pbdMPI/src/spmd_reduce.c
pbdMPI/src/spmd_send.c
pbdMPI/src/spmd_allgatherv.c
pbdMPI/src/Makevars.in
pbdMPI/src/spmd_communicator_spawn.c
pbdMPI/src/spmd_allreduce.c
pbdMPI/src/spmd_alltoallv.c
pbdMPI/src/spmd_sendrecv.c
pbdMPI/src/spmd_constant.h
pbdMPI/src/spmd_communicator.c
pbdMPI/src/pkg_dl.c
pbdMPI/src/msmpi.def
pbdMPI/src/pkg_constant.h
pbdMPI/src/Makevars.win
pbdMPI/src/spmd.c
pbdMPI/src/spmd_info.c
pbdMPI/src/pkg_global.h
pbdMPI/src/spmd_gatherv.c
pbdMPI/src/spmd_scatterv.c
pbdMPI/src/comm_api.h
pbdMPI/NAMESPACE
pbdMPI/demo
pbdMPI/demo/new_allgather.r
pbdMPI/demo/bcast_msg.r
pbdMPI/demo/simple_balance.r
pbdMPI/demo/seed.r
pbdMPI/demo/pbdLapply.r
pbdMPI/demo/allgather.r
pbdMPI/demo/allreduce.r
pbdMPI/demo/simple_io.r
pbdMPI/demo/divide.r
pbdMPI/demo/any_all.r
pbdMPI/demo/task_pull.r
pbdMPI/demo/bcast.r
pbdMPI/demo/scatter.r
pbdMPI/demo/reduce.r
pbdMPI/demo/alltoall.r
pbdMPI/demo/00Index
pbdMPI/demo/gather.r
pbdMPI/demo/new_allreduce.r
pbdMPI/demo/simple_pairs.r
pbdMPI/demo/pbdApply.r
pbdMPI/demo/sort.r
pbdMPI/INSTALL
pbdMPI/R
pbdMPI/R/spmd_allgatherv_obj.r
pbdMPI/R/comm_balance.r
pbdMPI/R/111_pbd_opt.r
pbdMPI/R/comm_seed.r
pbdMPI/R/spmd_communicator.r
pbdMPI/R/111_control_io.r
pbdMPI/R/spmd_reduce_obj.r
pbdMPI/R/spmd_scatterv.r
pbdMPI/R/comm_read.r
pbdMPI/R/comm_as_gbd.r
pbdMPI/R/api_apply.r
pbdMPI/R/get_winmpi.r
pbdMPI/R/comm_allcommon.r
pbdMPI/R/api_sapply.r
pbdMPI/R/spmd_bcast_obj.r
pbdMPI/R/spmd_wait.r
pbdMPI/R/spmd_gatherv_obj.r
pbdMPI/R/000_globalVariables.r
pbdMPI/R/comm_allpairs.r
pbdMPI/R/spmd_sendrecv_replace.r
pbdMPI/R/api_task_pull.r
pbdMPI/R/zzz.r.in
pbdMPI/R/spmd_send.r
pbdMPI/R/comm_matcharg.r
pbdMPI/R/mpi_apts.r
pbdMPI/R/comm_sort.r
pbdMPI/R/comm_dist.r
pbdMPI/R/comm_range.r
pbdMPI/R/get_conf.r
pbdMPI/R/api_apply_RC.r
pbdMPI/R/spmd_tool.r
pbdMPI/R/spmd_allreduce.r
pbdMPI/R/api_tool.r
pbdMPI/R/222_export_env.r
pbdMPI/R/windows
pbdMPI/R/windows/zzz.r
pbdMPI/R/comm_any_all.r
pbdMPI/R/comm_write.r
pbdMPI/R/spmd_irecv.r
pbdMPI/R/spmd_allgatherv.r
pbdMPI/R/111_control.r
pbdMPI/R/spmd_allcheck.r
pbdMPI/R/spmd_utility.r
pbdMPI/R/spmd_sendrecv.r
pbdMPI/R/comm_stopifnot.r
pbdMPI/R/spmd_gatherv.r
pbdMPI/R/api_split.r
pbdMPI/R/comm_pairwise.r
pbdMPI/R/spmd_info.r
pbdMPI/R/spmd_reduce.r
pbdMPI/R/spmd_communicator_spawn.r
pbdMPI/R/get_lib.r
pbdMPI/R/comm_base.r
pbdMPI/R/111_control_tp.r
pbdMPI/R/comm_errors.r
pbdMPI/R/spmd_scatterv_obj.r
pbdMPI/R/api_apply_general.r
pbdMPI/R/comm_tool.r
pbdMPI/R/spmd_alltoall.r
pbdMPI/R/comm_which.r
pbdMPI/R/api_lapply.r
pbdMPI/R/spmd_allreduce_obj.r
pbdMPI/R/spmd_bcast.r
pbdMPI/R/spmd_recv.r
pbdMPI/R/spmd_isend.r
pbdMPI/vignettes
pbdMPI/vignettes/pbdMPI-guide.Rnw
pbdMPI/vignettes/pbdMPI-include
pbdMPI/vignettes/pbdMPI-include/pbdMPI.bib
pbdMPI/vignettes/pbdMPI-include/03-faq.tex
pbdMPI/vignettes/pbdMPI-include/06-longvector.tex
pbdMPI/vignettes/pbdMPI-include/08-simplepairs.tex
pbdMPI/vignettes/pbdMPI-include/00-preamble.tex
pbdMPI/vignettes/pbdMPI-include/01-acknowledgement.tex
pbdMPI/vignettes/pbdMPI-include/02-performance.tex
pbdMPI/vignettes/pbdMPI-include/05-analog.tex
pbdMPI/vignettes/pbdMPI-include/01-copyright.tex
pbdMPI/vignettes/pbdMPI-include/07-simpleio.tex
pbdMPI/vignettes/pbdMPI-include/01-introduction.tex
pbdMPI/vignettes/pbdMPI-include/my_jss.cls
pbdMPI/vignettes/pbdMPI-include/04-windows_msmpi.tex
pbdMPI/vignettes/build_pdf.sh
pbdMPI/README.md
pbdMPI/MD5
pbdMPI/DESCRIPTION
pbdMPI/configure
pbdMPI/ChangeLog
pbdMPI/man
pbdMPI/man/ab_send-method.Rd
pbdMPI/man/aa_scatter-method.Rd
pbdMPI/man/aa_reduce-method.Rd
pbdMPI/man/vv_seed.Rd
pbdMPI/man/xx_comm_sort.Rd
pbdMPI/man/yy_api_apply.Rd
pbdMPI/man/dd_sourcetag.Rd
pbdMPI/man/ae_alltoall.Rd
pbdMPI/man/ww_comm_as_gbd.Rd
pbdMPI/man/dd_wait.Rd
pbdMPI/man/xx_comm_base.Rd
pbdMPI/man/xx_comm_allpairs.Rd
pbdMPI/man/xx_comm_Rprof.Rd
pbdMPI/man/xx_comm_dist.Rd
pbdMPI/man/vv_get_jid.Rd
pbdMPI/man/ww_comm_write.Rd
pbdMPI/man/11_d_control.Rd
pbdMPI/man/ab_recv-method.Rd
pbdMPI/man/dd_is.comm.null.Rd
pbdMPI/man/xx_comm_any_all.Rd
pbdMPI/man/aa_gather-method.Rd
pbdMPI/man/ac_isend-method.Rd
pbdMPI/man/xx_comm_range.Rd
pbdMPI/man/11_d_pbd_opt.Rd
pbdMPI/man/xx_comm_stop_warning.Rd
pbdMPI/man/xx_comm_which.Rd
pbdMPI/man/ad_sendrecv.replace-method.Rd
pbdMPI/man/aa_allreduce-method.Rd
pbdMPI/man/zz_spmd_internal.Rd
pbdMPI/man/zz_spmd_control.Rd
pbdMPI/man/aa_bcast-method.Rd
pbdMPI/man/cc_arrange.mpi.apts.Rd
pbdMPI/man/xx_comm_timer.Rd
pbdMPI/man/ad_sendrecv-method.Rd
pbdMPI/man/xx_comm_match_arg.Rd
pbdMPI/man/zz_comm_internal.Rd
pbdMPI/man/ac_irecv-method.Rd
pbdMPI/man/00_pbdMPI-package.Rd
pbdMPI/man/cc_comm.Rd
pbdMPI/man/ww_comm_read.Rd
pbdMPI/man/dd_info.Rd
pbdMPI/man/aa_allgather-method.Rd
pbdMPI/man/dd_prob.Rd
pbdMPI/man/ww_comm_balance.Rd
pbdMPI/man/xx_comm_pairwise.Rd
pbdMPI/man/yy_api_task_pull.Rd
pbdMPI/man/vv_print_cat.Rd
pbdMPI/configure.win
pbdMPI/cleanup