CPC G01W 1/00 (2013.01) [G06F 16/116 (2019.01); G01W 2001/006 (2013.01)] | 17 Claims |
1. A reanalysis ensemble service comprising:
a plurality of conversion utilities, each conversion utility configured to convert a specific one of a plurality of disparate climate reanalysis datasets from different sources to common format files that are temporally and spatially registered;
a data analytics platform for storing and operating on the different sourced common format files;
a service interface for mapping service requests to analytic operations performed on the different sourced common format files by the data analytics platform; and
a services library that dynamically creates data objects from one or more of the different sourced common format files in response to the analytic operations, and delivers the data objects to the service interface;
wherein each conversion utility comprises;
a sequencer utility for temporally and spatially registering one of the disparate climate reanalysis datasets, encoding the one of the disparate climate reanalysis data sets into sequence files, and for partitioning the sequence files to include a composite key having a timestamp and a climate variable name;
a mapper class for filtering the partitioned sequence files; and
a reducer class for creating subsets of the filtered sequence files to be stored in the data analytics platform.
|