xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge "Omaha #3831 Alleviate memory usage in Template creation Change-Id: Iab5c75280d5b2fd14f12ef14e148d3c6bfaf85c2" into omaha_14.4.1

Browse source 
Former-commit-id: 306c64193d02d065bba1c792e13aa34bafb6e9c3
This commit is contained in:
Nate Jensen 2014-12-03 14:14:36 -06:00 • committed by Gerrit Code Review
commit 3b0fdec2e5
2 changed files with 90 additions and 82 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
edexOsgi/com.raytheon.uf.common.dataplugin.ffmp/src/com/raytheon/uf/common/dataplugin/ffmp/FFMPTemplates.java
View file

@ -90,6 +90,7 @@ import com.vividsolutions.jts.io.WKBReader;
* 06/10/13 2085 njensen Use countyMap for efficiency * 06/10/13 2085 njensen Use countyMap for efficiency
* 07/01/13 2155 dhladky Fixed duplicate pfafs that were in domainList arrays from overlapping domains. * 07/01/13 2155 dhladky Fixed duplicate pfafs that were in domainList arrays from overlapping domains.
* 07/15/13 2184 dhladky Remove all HUC's for storage except ALL * 07/15/13 2184 dhladky Remove all HUC's for storage except ALL
* Nov 18, 2014 3831 dhladky StatusHandler logging. Proper list sizing. Geometry chunk sizing.
* </pre> * </pre>
* *
* @author dhladky * @author dhladky
@ -333,7 +334,7 @@ public class FFMPTemplates {
long[] list = readDomainList(huc, cwa, dataKey); long[] list = readDomainList(huc, cwa, dataKey);
if (huc.equals(FFMPRecord.ALL)) { if (huc.equals(FFMPRecord.ALL)) {
map = new LinkedHashMap<Long, FFMPBasinMetaData>(); map = new LinkedHashMap<>(list.length, 1.0f);
HashMap<Long, FFMPBasinMetaData> protoMap = (HashMap<Long, FFMPBasinMetaData>) readDomainMap( HashMap<Long, FFMPBasinMetaData> protoMap = (HashMap<Long, FFMPBasinMetaData>) readDomainMap(
dataKey, huc, cwa); dataKey, huc, cwa);
// add them to the master hash // add them to the master hash
@ -359,12 +360,12 @@ public class FFMPTemplates {
*/ */
private LinkedHashMap<String, FFMPVirtualGageBasinMetaData> readVGBFile( private LinkedHashMap<String, FFMPVirtualGageBasinMetaData> readVGBFile(
String name, String cwa, String dataKey) { String name, String cwa, String dataKey) {
LinkedHashMap<String, FFMPVirtualGageBasinMetaData> map = new LinkedHashMap<String, FFMPVirtualGageBasinMetaData>();
HashMap<String, FFMPVirtualGageBasinMetaData> protoMap = readVGBDomainMap( HashMap<String, FFMPVirtualGageBasinMetaData> protoMap = readVGBDomainMap(
dataKey, cwa); dataKey, cwa);
String[] list = readVGBDomainList(dataKey, cwa); String[] list = readVGBDomainList(dataKey, cwa);
LinkedHashMap<String, FFMPVirtualGageBasinMetaData> map = new LinkedHashMap<String, FFMPVirtualGageBasinMetaData>(list.length, 1.0f);
// construct ordered map // construct ordered map
for (String lid : list) { for (String lid : list) {
map.put(lid, protoMap.get(lid)); map.put(lid, protoMap.get(lid));
@ -413,13 +414,13 @@ public class FFMPTemplates {
list = null; list = null;
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: Write VGB: cwa: "+cwa+" dataKey: "+dataKey, se);
} catch (FileNotFoundException fnfe) { } catch (FileNotFoundException fnfe) {
fnfe.printStackTrace(); statusHandler.error("File Not found Exception: Write VGB: cwa: "+cwa+" dataKey: "+dataKey, fnfe);
} catch (IOException ioe) { } catch (IOException ioe) {
ioe.printStackTrace(); statusHandler.error("IO Exception: Write VGB: cwa: "+cwa+" dataKey: "+dataKey, ioe);
} catch (LocalizationOpFailedException e) { } catch (LocalizationOpFailedException e) {
e.printStackTrace(); statusHandler.error("Localization Exception: Write VGB: cwa: "+cwa+" dataKey: "+dataKey, e);
} }
} }
@ -486,13 +487,13 @@ public class FFMPTemplates {
list = null; list = null;
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: Write Template: cwa: "+cwa+" dataKey:"+dataKey+" huc: "+huc, se);
} catch (FileNotFoundException fnfe) { } catch (FileNotFoundException fnfe) {
fnfe.printStackTrace(); statusHandler.error("File Not found Exception: Write Template: cwa: "+cwa+" dataKey:"+dataKey+" huc: "+huc, fnfe);
} catch (IOException ioe) { } catch (IOException ioe) {
ioe.printStackTrace(); statusHandler.error("IO Exception: Write Template: cwa: "+cwa+" dataKey:"+dataKey+" huc: "+huc, ioe);
} catch (LocalizationOpFailedException e) { } catch (LocalizationOpFailedException e) {
e.printStackTrace(); statusHandler.error("Localization Exception: Write Template: cwa: "+cwa+" dataKey:"+dataKey+" huc: "+huc, e);
} }
} }
@ -843,7 +844,7 @@ public class FFMPTemplates {
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Find Basin by lon lat failed: dataKey: "+dataKey+ " coor:"+coor.toString(), e);
} }
return null; return null;
@ -1007,7 +1008,7 @@ public class FFMPTemplates {
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Failed to lookup County: dataKey: "+dataKey, e);
} }
FFMPCounties counties = new FFMPCounties(countyList); FFMPCounties counties = new FFMPCounties(countyList);
@ -1095,7 +1096,7 @@ public class FFMPTemplates {
siteExtents = FFMPUtils.getGeometryText(geo); siteExtents = FFMPUtils.getGeometryText(geo);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Couldn't lookup site Extents!: dataKey: "+dataKey, e);
} }
} else if (primeSource.getDataType().equals( } else if (primeSource.getDataType().equals(
FFMPSourceConfigurationManager.DATA_TYPE.RADAR.getDataType())) { FFMPSourceConfigurationManager.DATA_TYPE.RADAR.getDataType())) {
@ -1739,8 +1740,23 @@ public class FFMPTemplates {
WKBReader reader = new WKBReader(); WKBReader reader = new WKBReader();
FFMPBasinMetaData basin = null; FFMPBasinMetaData basin = null;
int upstreamDepth = 0; int upstreamDepth = 0;
String compositeKey = siteKey + cwa;
SoftReference<Map<Long, Geometry>> rawGeomRef = cwaRawGeometries
.get(compositeKey);
Map<Long, Geometry> pfafGeometries = null;
if (rawGeomRef != null) {
pfafGeometries = rawGeomRef.get();
}
if (results != null && results.length > 0) { if (results != null && results.length > 0) {
if (pfafGeometries == null) {
pfafGeometries = new HashMap<Long, Geometry>(results.length, 1.0f);
cwaRawGeometries.put(compositeKey,
new SoftReference<Map<Long, Geometry>>(pfafGeometries));
}
for (int i = 0; i < results.length; i++) { for (int i = 0; i < results.length; i++) {
Object[] row = (Object[]) results[i]; Object[] row = (Object[]) results[i];
basin = FFMPUtils.getMetaDataBasin(row, mode.getMode()); basin = FFMPUtils.getMetaDataBasin(row, mode.getMode());
@ -1755,11 +1771,12 @@ public class FFMPTemplates {
if ((row.length >= (upstreamDepth + 9)) if ((row.length >= (upstreamDepth + 9))
&& (row[upstreamDepth + 9] != null)) { && (row[upstreamDepth + 9] != null)) {
try { try {
addRawGeometry(siteKey, cwa, basin.getPfaf(), reader pfafGeometries.put(basin.getPfaf(), reader
.read((byte[]) row[upstreamDepth + 9]) .read((byte[]) row[upstreamDepth + 9])
.buffer(0)); .buffer(0));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Failure to add rawGeometry in loadBasins: "+siteKey, e);
} }
} }
} }
@ -1977,9 +1994,9 @@ public class FFMPTemplates {
list = SerializationUtil.transformFromThrift(long[].class, list = SerializationUtil.transformFromThrift(long[].class,
FileUtil.file2bytes(f.getFile(), true)); FileUtil.file2bytes(f.getFile(), true));
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: Read Domain: cwa: "+cwa+" dataKey: "+dataKey+" huc: "+huc, se);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); statusHandler.error("IO Exception: Read Domain: cwa: "+cwa+" dataKey: "+dataKey+" huc: "+huc, e);
} }
return list; return list;
@ -2014,9 +2031,9 @@ public class FFMPTemplates {
FileUtil.file2bytes(f.getFile(), true)); FileUtil.file2bytes(f.getFile(), true));
} }
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: Domain Map: "+dataKey+" cwa:"+cwa+" huc: "+huc, se);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); statusHandler.error("IO Exception: Domain Map: "+dataKey+" cwa:"+cwa+" huc: "+huc, e);
} }
return map; return map;
@ -2045,9 +2062,9 @@ public class FFMPTemplates {
.transformFromThrift(HashMap.class, .transformFromThrift(HashMap.class,
FileUtil.file2bytes(f.getFile(), true)); FileUtil.file2bytes(f.getFile(), true));
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: Virtual Basins: "+dataKey+" cwa: "+cwa, se);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); statusHandler.error("IO Exception: Virtual Basins: "+dataKey+" cwa: "+cwa, e);
} }
return map; return map;
@ -2073,9 +2090,9 @@ public class FFMPTemplates {
list = SerializationUtil.transformFromThrift(String[].class, list = SerializationUtil.transformFromThrift(String[].class,
FileUtil.file2bytes(f.getFile(), true)); FileUtil.file2bytes(f.getFile(), true));
} catch (SerializationException se) { } catch (SerializationException se) {
se.printStackTrace(); statusHandler.error("Serialization Exception: : Read Virtual Domain: cwa: "+cwa+" dataKey: "+dataKey, se);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); statusHandler.error("IO Exception: : Read Virtual Domain: cwa: "+cwa+" dataKey: "+dataKey, e);
} }
return list; return list;
@ -2119,26 +2136,6 @@ public class FFMPTemplates {
} }
} }
public void addRawGeometry(String siteKey, String cwa, Long pfaf, Geometry g) {
String compositeKey = siteKey + cwa;
SoftReference<Map<Long, Geometry>> rawGeomRef = cwaRawGeometries
.get(compositeKey);
Map<Long, Geometry> pfafGeometries = null;
if (rawGeomRef != null) {
pfafGeometries = rawGeomRef.get();
}
if (pfafGeometries == null) {
pfafGeometries = new HashMap<Long, Geometry>(4000);
cwaRawGeometries.put(compositeKey,
new SoftReference<Map<Long, Geometry>>(pfafGeometries));
}
pfafGeometries.put(pfaf, g);
}
/** /**
* *
* @param cwa * @param cwa

85
edexOsgi/com.raytheon.uf.common.dataplugin.ffmp/src/com/raytheon/uf/common/dataplugin/ffmp/FFMPUtils.java
View file

@ -59,6 +59,8 @@ import com.raytheon.uf.common.monitor.scan.ScanUtils;
import com.raytheon.uf.common.mpe.util.XmrgFile; import com.raytheon.uf.common.mpe.util.XmrgFile;
import com.raytheon.uf.common.serialization.comm.RequestRouter; import com.raytheon.uf.common.serialization.comm.RequestRouter;
import com.raytheon.uf.common.site.SiteMap; import com.raytheon.uf.common.site.SiteMap;
import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.vividsolutions.jts.geom.Coordinate; import com.vividsolutions.jts.geom.Coordinate;
import com.vividsolutions.jts.geom.Geometry; import com.vividsolutions.jts.geom.Geometry;
import com.vividsolutions.jts.geom.GeometryFactory; import com.vividsolutions.jts.geom.GeometryFactory;
@ -90,6 +92,7 @@ import com.vividsolutions.jts.io.WKTWriter;
* 09/05/14 DR 17346 G. Zhang Fixed issue with DB return types. * 09/05/14 DR 17346 G. Zhang Fixed issue with DB return types.
* Apr 21, 2014 2060 njensen Remove dependency on grid dataURI column * Apr 21, 2014 2060 njensen Remove dependency on grid dataURI column
* Apr 22, 2014 2984 njensen Remove dependency on edex/CoreDao * Apr 22, 2014 2984 njensen Remove dependency on edex/CoreDao
* Nov 18, 2014 3831 dhladky StatusHandler logging. Proper list sizing.
* *
* </pre> * </pre>
* @author dhladky * @author dhladky
@ -114,6 +117,9 @@ public class FFMPUtils {
public static float MISSING = -99999.0f; public static float MISSING = -99999.0f;
private static NumberFormat formatter = new DecimalFormat("#.##"); private static NumberFormat formatter = new DecimalFormat("#.##");
private static final IUFStatusHandler statusHandler = UFStatus
.getHandler(FFMPUtils.class);
public static byte[] STREAM_FILL = new byte[] { // public static byte[] STREAM_FILL = new byte[] { //
0x40, 0x08, 0x40, 0x08, // 0x40, 0x08, 0x40, 0x08, //
@ -158,7 +164,7 @@ public class FFMPUtils {
* @return * @return
*/ */
public static ArrayList<Long> getAllPfafs(String extents, String mode) { public static ArrayList<Long> getAllPfafs(String extents, String mode) {
ArrayList<Long> pfafs = new ArrayList<Long>(); ArrayList<Long> pfafs = null;
String sql = "select pfaf_id " + " from " + FFMP_TABLE + " where" String sql = "select pfaf_id " + " from " + FFMP_TABLE + " where"
+ " ST_Contains(ST_GeomFromText('" + extents + "', 4326), " + " ST_Contains(ST_GeomFromText('" + extents + "', 4326), "
+ ScanUtils.getHighResolutionLevel("ffmp_basins") + ")"; + ScanUtils.getHighResolutionLevel("ffmp_basins") + ")";
@ -168,6 +174,7 @@ public class FFMPUtils {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
Object[] results = sq.dbRequest(sql, FFMPUtils.MAPS_DB); Object[] results = sq.dbRequest(sql, FFMPUtils.MAPS_DB);
pfafs = new ArrayList<Long>(results.length);
if (results.length > 0) { if (results.length > 0) {
if (mode.equals("CAVE")) { if (mode.equals("CAVE")) {
@ -190,7 +197,7 @@ public class FFMPUtils {
} }
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error querying allPfafs: +sql: "+sql, e);
} }
return pfafs; return pfafs;
@ -205,7 +212,7 @@ public class FFMPUtils {
public static LinkedHashMap<String, FFMPVirtualGageBasinMetaData> getVirtualGageBasins( public static LinkedHashMap<String, FFMPVirtualGageBasinMetaData> getVirtualGageBasins(
double extent, String cwa, String mode) { double extent, String cwa, String mode) {
LinkedHashMap<String, FFMPVirtualGageBasinMetaData> virtualBasins = new LinkedHashMap<String, FFMPVirtualGageBasinMetaData>(); LinkedHashMap<String, FFMPVirtualGageBasinMetaData> virtualBasins = null;
/* /*
* DR 13228 state added to the below query * DR 13228 state added to the below query
*/ */
@ -215,6 +222,7 @@ public class FFMPUtils {
+ "and dur < 2000)"; + "and dur < 2000)";
try { try {
Object[] results = executeSqlQuery(sql, ShefConstants.IHFS); Object[] results = executeSqlQuery(sql, ShefConstants.IHFS);
virtualBasins = new LinkedHashMap<String, FFMPVirtualGageBasinMetaData>(results.length, 1.0f);
Geometry poly = getCwaGeometry(cwa, mode); Geometry poly = getCwaGeometry(cwa, mode);
PreparedGeometry pg = PreparedGeometryFactory.prepare(poly); PreparedGeometry pg = PreparedGeometryFactory.prepare(poly);
Coordinate coor = poly.getCentroid().getCoordinate(); Coordinate coor = poly.getCentroid().getCoordinate();
@ -234,7 +242,7 @@ public class FFMPUtils {
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying Virtual Gage's: +sql: "+sql, e);
} }
return virtualBasins; return virtualBasins;
@ -248,12 +256,13 @@ public class FFMPUtils {
private static ArrayList<String> determineUpstreamDepth() { private static ArrayList<String> determineUpstreamDepth() {
ISpatialQuery sq = null; ISpatialQuery sq = null;
Object[] results = null; Object[] results = null;
ArrayList<String> upstreams = new ArrayList<String>(); ArrayList<String> upstreams = null;
String sql = "select column_name from information_schema.columns where table_name='ffmp_basins'"; String sql = "select column_name from information_schema.columns where table_name='ffmp_basins'";
try { try {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
results = sq.dbRequest(sql, MAPS_DB); results = sq.dbRequest(sql, MAPS_DB);
upstreams = new ArrayList<String>(results.length);
int j = 1; int j = 1;
if (results.length > 0) { if (results.length > 0) {
@ -266,7 +275,7 @@ public class FFMPUtils {
} }
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error determining upstream depth: +sql: "+sql, e);
} }
return upstreams; return upstreams;
@ -295,7 +304,7 @@ public class FFMPUtils {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
results = sq.dbRequest(sql.toString(), MAPS_DB); results = sq.dbRequest(sql.toString(), MAPS_DB);
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Failed to lookup Huc Parameters: sql: "+sql, e);
} }
String[] pfafs = new String[results.length]; String[] pfafs = new String[results.length];
@ -388,7 +397,7 @@ public class FFMPUtils {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
results = sq.dbRequest(sql.toString(), MAPS_DB); results = sq.dbRequest(sql.toString(), MAPS_DB);
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error getting basins: sql:"+sql+"\n", e);
} }
return results; return results;
@ -405,8 +414,7 @@ public class FFMPUtils {
* @return * @return
*/ */
public static Map<Long, Geometry> getRawGeometries(Collection<Long> pfafs) { public static Map<Long, Geometry> getRawGeometries(Collection<Long> pfafs) {
HashMap<Long, Geometry> rval = new HashMap<Long, Geometry>( HashMap<Long, Geometry> rval = null;
(int) (pfafs.size() * 1.3) + 1);
if (pfafs.size() > 0) { if (pfafs.size() > 0) {
StringBuilder builder = new StringBuilder(); StringBuilder builder = new StringBuilder();
builder.append("SELECT pfaf_id, AsBinary(" builder.append("SELECT pfaf_id, AsBinary("
@ -430,8 +438,9 @@ public class FFMPUtils {
try { try {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
results = sq.dbRequest(builder.toString(), MAPS_DB); results = sq.dbRequest(builder.toString(), MAPS_DB);
rval = new HashMap<Long, Geometry>(results.length, 1.0f);
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error querying Raw Geometries: +sql: "+builder.toString(), e);
} }
WKBReader wkbReader = new WKBReader(); WKBReader wkbReader = new WKBReader();
@ -443,7 +452,7 @@ public class FFMPUtils {
Geometry g = readGeometry(columns[1], wkbReader); Geometry g = readGeometry(columns[1], wkbReader);
rval.put(pfaf, g); rval.put(pfaf, g);
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); statusHandler.error("Error parsing Raw Geometries!", e);
} }
} }
} }
@ -567,7 +576,7 @@ public class FFMPUtils {
} }
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error retrieving COUNTY, pfaf: "+pfaf, e);
} }
return county; return county;
@ -593,12 +602,13 @@ public class FFMPUtils {
+ "', 4326), county." + resolution + ")" + "', 4326), county." + resolution + ")"
+ " order by county.fips desc"; + " order by county.fips desc";
ArrayList<Long> keys = new ArrayList<Long>(); ArrayList<Long> keys = null;
ISpatialQuery sq = null; ISpatialQuery sq = null;
try { try {
sq = SpatialQueryFactory.create(); sq = SpatialQueryFactory.create();
Object[] results = sq.dbRequest(sql, FFMPUtils.MAPS_DB); Object[] results = sq.dbRequest(sql, FFMPUtils.MAPS_DB);
keys = new ArrayList<Long>(results.length);
if (results != null) { if (results != null) {
if (results.length > 0) { if (results.length > 0) {
@ -612,7 +622,7 @@ public class FFMPUtils {
} }
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error retreiving COUNTY FIPS list! sql: "+sql, e);
} }
return removeDuplicates(keys); return removeDuplicates(keys);
@ -642,7 +652,7 @@ public class FFMPUtils {
* @param gid * @param gid
* @return * @return
*/ */
@SuppressWarnings("unchecked") @SuppressWarnings({ "unchecked", "rawtypes" })
public static ArrayList<?> getCountyInfo(Long fips, String mode) { public static ArrayList<?> getCountyInfo(Long fips, String mode) {
String ftxt = (fips >= 10000 ? "" + fips : "0" + fips);// DR 15108: add String ftxt = (fips >= 10000 ? "" + fips : "0" + fips);// DR 15108: add
// a leading 0 to // a leading 0 to
@ -662,13 +672,14 @@ public class FFMPUtils {
// Template // Template
// generation. // generation.
ISpatialQuery sq1 = null; ISpatialQuery sq1 = null;
ArrayList<Long> gids = new ArrayList<Long>(); ArrayList<Long> gids = null;
try { try {
sq1 = SpatialQueryFactory.create(); sq1 = SpatialQueryFactory.create();
Object[] results = sq1.dbRequest(sql1, FFMPUtils.MAPS_DB); Object[] results = sq1.dbRequest(sql1, FFMPUtils.MAPS_DB);
if (results != null) { if (results != null) {
gids = new ArrayList<Long>(results.length);
if (results.length > 0) { if (results.length > 0) {
for (int i = 0; i < results.length; i++) { for (int i = 0; i < results.length; i++) {
gids.add(((Number) results[i]).longValue()); gids.add(((Number) results[i]).longValue());
@ -677,11 +688,9 @@ public class FFMPUtils {
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error retreiving COUNTY INFO, part 1! sql: "+sql1, e);
} }
@SuppressWarnings("rawtypes")
ArrayList info = new ArrayList();
Geometry geom = null; Geometry geom = null;
String countyName = null; String countyName = null;
String state = null; String state = null;
@ -705,7 +714,7 @@ public class FFMPUtils {
for (int i = 0; i < results.length; i++) { for (int i = 0; i < results.length; i++) {
Object[] results2 = (Object[]) results[i]; Object[] results2 = (Object[]) results[i];
WKBReader wkbReader = new WKBReader(); WKBReader wkbReader = new WKBReader();
if (results2[0] != null) { if (results2[0] != null) {
if (geom == null) { if (geom == null) {
geom = readGeometry(results2[0], wkbReader); geom = readGeometry(results2[0], wkbReader);
@ -727,12 +736,13 @@ public class FFMPUtils {
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error retreiving COUNTY INFO, part 2! sql: "+sql, e);
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); statusHandler.error("Error parsing COUNTY INFO!", e);
} }
} }
ArrayList info = new ArrayList(3);
info.add(geom); info.add(geom);
info.add(countyName); info.add(countyName);
info.add(state); info.add(state);
@ -767,7 +777,7 @@ public class FFMPUtils {
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error retrieving basins: sql: "+sql+"\n basin: "+basinId);
} }
return pfaf; return pfaf;
@ -801,7 +811,7 @@ public class FFMPUtils {
coor = new Coordinate(lon, lat); coor = new Coordinate(lon, lat);
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error getting radar geometry description: "+sql, e);
} }
return coor; return coor;
@ -829,10 +839,10 @@ public class FFMPUtils {
try { try {
geo = readGeometry(results[0], wkbReader); geo = readGeometry(results[0], wkbReader);
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); statusHandler.error("Error parsing CWA geometry!", e);
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error querying CWA geometry: "+sql, e);
} }
return geo; return geo;
@ -864,7 +874,7 @@ public class FFMPUtils {
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying CWA descriptions!: "+sql, e);
} }
return cwas; return cwas;
@ -899,7 +909,7 @@ public class FFMPUtils {
rfc = SiteMap.getInstance().getSite4LetterId(rfc.toUpperCase()); rfc = SiteMap.getInstance().getSite4LetterId(rfc.toUpperCase());
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying RFC designation: "+sql, e);
} }
return rfc; return rfc;
@ -912,7 +922,7 @@ public class FFMPUtils {
* @return * @return
*/ */
public static Set<String> getFFGParameters(String rfc) { public static Set<String> getFFGParameters(String rfc) {
Set<String> ffgHash = new HashSet<String>(); Set<String> ffgHash = null;
/** /**
* Had to add this bit of code for ncgrib models * Had to add this bit of code for ncgrib models
@ -926,14 +936,15 @@ public class FFMPUtils {
try { try {
DbQueryResponse response = (DbQueryResponse) RequestRouter DbQueryResponse response = (DbQueryResponse) RequestRouter
.route(request); .route(request);
ffgHash = new HashSet<String>(response.getResults().size(), 1.0f);
for (Map<String, Object> map : response.getResults()) { for (Map<String, Object> map : response.getResults()) {
String key = (String) map String key = (String) map
.get(GridConstants.PARAMETER_ABBREVIATION); .get(GridConstants.PARAMETER_ABBREVIATION);
ffgHash.add(key); ffgHash.add(key);
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying FFG parameters: "+request.toString(), e);
} }
return ffgHash; return ffgHash;
@ -959,7 +970,7 @@ public class FFMPUtils {
.route(request); .route(request);
return response.getEntityObjects(GridRecord.class)[0].getDataURI(); return response.getEntityObjects(GridRecord.class)[0].getDataURI();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying FFG Data URIS: "+request.toString(), e);
} }
return null; return null;
@ -984,7 +995,7 @@ public class FFMPUtils {
uri = (String) results[0]; uri = (String) results[0];
} }
} catch (SpatialException e) { } catch (SpatialException e) {
e.printStackTrace(); statusHandler.error("Error querying RADAR Data URI: "+sql, e);
} }
return uri; return uri;
@ -1012,7 +1023,7 @@ public class FFMPUtils {
subGrid = new HRAPSubGrid(extent, gridFactor); subGrid = new HRAPSubGrid(extent, gridFactor);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error looking up XMRG geometry: "+xmrg.toString(), e);
} }
return MapUtil.getGridGeometry(subGrid); return MapUtil.getGridGeometry(subGrid);
@ -1040,7 +1051,7 @@ public class FFMPUtils {
subGrid = new HRAPSubGrid(extent, gridFactor); subGrid = new HRAPSubGrid(extent, gridFactor);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); statusHandler.error("Error querying XMRG sub grid: "+xmrg.toString(), e);
} }
return subGrid; return subGrid;