stub out casting datatypes in conversion records

pythonApi/grib_to_arrow.cpp

@@ -7,7 +7,7 @@
 #include "../src/exceptions/invalidcsvexception.hpp"
 #include "../src/exceptions/invalidschemaexception.hpp"
 
-#define USE_CMAKE
+//#define USE_CMAKE
 
 #ifdef USE_CMAKE
  #include "../pybind11/include/pybind11/pybind11.h"

src/gribreader.cpp

@@ -86,6 +86,34 @@ void GribReader::validateConversionFields(std::shared_ptr<arrow::Table> location
  }
 }
 
+void GribReader::castConversionFields(std::shared_ptr<arrow::Table> locations, std::string table_name) {
+ auto table = locations.get();
+
+ std::vector<std::string> f64_cols = {"addition_value", 
+ "subtraction_value",
+ "multiplication_value",
+ "division_value",
+ "ceiling_value"};
+
+ for (auto colName: f64_cols) {
+ auto col = table->GetColumnByName(colName).get();
+
+ cp::CastOptions castOptions;
+ castOptions.to_type = arrow::float64().get();
+
+ auto x = arrow::float64().get();
+ for (auto chunk : col->chunks()) {
+ auto arr = chunk.get();
+ auto result = cp::Cast(*arr, castOptions.to_type, castOptions);
+ if (result.ok()) {
+ auto converted = result.ValueOrDie();
+ //Ok it's converted do we need to update the table ?
+ }
+ }
+ }
+
+}
+
 GribReader GribReader::withLocations(std::string path){
 
  //Reads a CSV with the location data and enriches it with a row_number / surrogate_key

src/gribreader.hpp

@@ -60,6 +60,7 @@ class GribReader
  std::shared_ptr<arrow::Table> getTableFromCsv(std::string path, arrow::csv::ConvertOptions convertOptions);
  arrow::Result<std::shared_ptr<arrow::Array>> createSurrogateKeyCol(long numberOfRows);
  void validateConversionFields(std::shared_ptr<arrow::Table> locations, std::string table_name);
+ void castConversionFields(std::shared_ptr<arrow::Table> locations, std::string table_name) ;
 
 
 };