AnEnReadGribMPI provides the functionality to read the Grib2 format in parallel with MPI.
More...
#include <AnEnReadGribMPI.h>
|
| AnEnReadGribMPI () |
|
| AnEnReadGribMPI (const AnEnReadGribMPI &orig) |
|
| AnEnReadGribMPI (Verbose master_verbose) |
|
| AnEnReadGribMPI (Verbose master_verbose, Verbose worker_verbose) |
|
virtual | ~AnEnReadGribMPI () |
|
void | readForecasts (Forecasts &forecasts, const std::vector< ParameterGrib > &grib_parameters, const std::vector< std::string > &files, const std::string ®ex_str, unsigned long unit_in_seconds=3600, bool delimited=false, std::vector< int > stations_index={}) const |
|
| AnEnReadGrib () |
|
| AnEnReadGrib (const AnEnReadGrib &orig) |
|
| AnEnReadGrib (Verbose verbose) |
|
virtual | ~AnEnReadGrib () |
|
void | readForecasts (Forecasts &forecasts, const std::vector< ParameterGrib > &grib_parameters, const std::vector< std::string > &files, const std::string ®ex_str, size_t unit_in_seconds=3600, bool delimited=false, std::vector< int > stations_index={}) const |
|
AnEnReadGribMPI provides the functionality to read the Grib2 format in parallel with MPI.
◆ AnEnReadGribMPI() [1/4]
AnEnReadGribMPI::AnEnReadGribMPI |
( |
| ) |
|
◆ AnEnReadGribMPI() [2/4]
◆ AnEnReadGribMPI() [3/4]
AnEnReadGribMPI::AnEnReadGribMPI |
( |
Verbose |
master_verbose | ) |
|
◆ AnEnReadGribMPI() [4/4]
AnEnReadGribMPI::AnEnReadGribMPI |
( |
Verbose |
master_verbose, |
|
|
Verbose |
worker_verbose |
|
) |
| |
◆ ~AnEnReadGribMPI()
AnEnReadGribMPI::~AnEnReadGribMPI |
( |
| ) |
|
|
virtual |
◆ readForecasts()
void AnEnReadGribMPI::readForecasts |
( |
Forecasts & |
forecasts, |
|
|
const std::vector< ParameterGrib > & |
grib_parameters, |
|
|
const std::vector< std::string > & |
files, |
|
|
const std::string & |
regex_str, |
|
|
unsigned long |
unit_in_seconds = 3600 , |
|
|
bool |
delimited = false , |
|
|
std::vector< int > |
stations_index = {} |
|
) |
| const |
Read grib files in parallel. This function has the same signature as AnEnReadGrib::readForecasts.
Please note that, it is assumed that the executable is launched with MPI launcher program, e.g. mpirun or mpiexec, with multiple processes. This function assign different tasks to different processes based on the process ID, but this function DOES NOT terminate any process. The developer is responsible to terminate any processes in the main function.
- Parameters
-
forecasts | Forecasts |
grib_parameters | Parameters to read |
files | Files to read |
regex_str | Regular expression to extract day, cycle, and flt information |
unit_in_seconds | The number of seconds associated with the unit of flt and cycle |
delimited | Whether the day string to be extracted are delimited |
stations_index | Stations index to read |
◆ worker_verbose_
Verbose AnEnReadGribMPI::worker_verbose_ |
|
private |
The documentation for this class was generated from the following files: