casting / conversion

src/gribmessage.cpp

@@ -229,6 +229,7 @@ using namespace std;
 
  GribMessage::~GribMessage() {
  //printf("Destuctor called on handle %p\n", h);
+ //codes_grib_nearest_delete()
  codes_handle_delete(h);
  }
 
@@ -345,6 +346,9 @@ using namespace std;
  free(distances);
  }
 
+
+
+
  grib_nearest_find_multiple(h,1, inlats, inlons, 
  numberOfPoints, outlats, outlons, outvalues, distances, indexes);
 

src/gribreader.cpp

@@ -95,23 +95,37 @@ void GribReader::castConversionFields(std::shared_ptr<arrow::Table> locations, s
  "division_value",
  "ceiling_value"};
 
+ std::vector<std::shared_ptr<arrow::ChunkedArray>> resultsArray;
  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();
+ auto chunkVector = new arrow::ArrayVector();
  for (auto chunk : col->chunks()) {
  auto arr = chunk.get();
- auto result = cp::Cast(*arr, castOptions.to_type, castOptions);
+ auto result = cp::Cast(*arr, arrow::float64().get(), castOptions);
  if (result.ok()) {
  auto converted = result.ValueOrDie();
- //Ok it's converted do we need to update the table ?
+ chunkVector->emplace_back(converted);
+ } else{
+ std::string errMsg = "Unable to cast conversion column " + colName + " to float64";
+ throw new InvalidSchemaException(errMsg);
  }
  }
+ auto chunkedArrayResult = col->Make(*chunkVector, arrow::float64());
+ if(chunkedArrayResult.ok()) {
+ resultsArray.push_back(chunkedArrayResult.ValueOrDie());
+ }else {
+ std::string errMsg = "Unable to create arrow column for column " + colName;
+ throw new InvalidSchemaException(errMsg);
+ }
+
  }
 
+
 }
 
 GribReader GribReader::withLocations(std::string path){
@@ -375,14 +389,9 @@ std::shared_ptr<arrow::Table> GribReader::getTableFromCsv(std::string path, arro
  throw UnableToCreateArrowTableReaderException(errDetails);
  }
 
-
-
-
  } else {
  throw NoSuchLocationsFileException(path);
  }
-
-
 
 }