work on kriging

Author: moovida

hmachine/src/main/java/org/hortonmachine/hmachine/geoframe/TestKriging.java

@@ -31,6 +31,8 @@ public TestKriging() {
 					GeoFrameGeoTable.HYDRO_METEO_STATION.tableName() + " WHERE " + //
 					HydroMeteoStation.TYPE.columnName() + " = '" + HydroMeteoStationSchema.StationType.METEO + "'").intValue();
 			valueReader.pMaxId = maxId;
+			valueReader.preCacheData();
+			
 			var krigingInterpolator = new KrigingAtCentroid();
 			krigingInterpolator.inGeoframeDBPath = geoframeGpkg;
 			krigingInterpolator.inVariableType = VarSchema.EnvironmentalVariableType.TEMPERATURE.getId();

hmachine/src/main/java/org/hortonmachine/hmachine/geoframe/utils/KrigingAtCentroid.java

@@ -127,8 +127,6 @@ public void init() {
 	public void process() throws Exception {
 		HashMap<Integer, double[]> h = null;
 
-		inGeoframeDb = EDb.GEOPACKAGE.getSpatialDb();
-		inGeoframeDb.open(inGeoframeDBPath);
 		SimpleFeatureCollection inStations = SpatialDbsImportUtils.tableToFeatureFCollection(inGeoframeDb,
 				GeoFrameGeoTable.HYDRO_METEO_STATION.getSchema().getSQLName(), -1, -1, null,
 				HydroMeteoStation.TYPE.columnName() + "='" + StationType.METEO + "'");
@@ -192,7 +190,6 @@ private void processTimestep(double[] variableMap, StationsSelection stations, S
 			HashMap<Integer, double[]> out = kriging.outData;
 
 
-			
 			inGeoframeDb.execOnConnection(conn -> {
 				boolean autoCommit = conn.getAutoCommit();
 				conn.setAutoCommit(false);
@@ -212,7 +209,6 @@ private void processTimestep(double[] variableMap, StationsSelection stations, S
 				}
 				return null;
 			});
-
 		} catch (Exception e) {
 			e.printStackTrace();
 		}