pointMap = new HashMap<>();
-
- for (PluginDataObject p : pdo) {
- if (!(p instanceof HydroLdadRecord)) {
- continue;
- }
-
- File f = this.dao.getFullFilePath(p);
-
- PointDataContainer pdc = pointMap.get(f);
- if (pdc == null) {
- pdc = PointDataContainer.build(this.description);
- pointMap.put(f, pdc);
- }
-
- HydroLdadRecord hydroRecord = (HydroLdadRecord) p;
- PointDataView pdv = buildView(pdc, hydroRecord);
- hydroRecord.setPointDataView(pdv);
- }
- }
- return pdo;
- }
-
- private PointDataView buildView(PointDataContainer container,
- HydroLdadRecord record) {
- PointDataView pdv = container.append();
- if (record.getObservationTime() != null) {
- pdv.setLong("timeObs", record.getDataTime().getRefTime().getTime());
- }
- if (record.getLocation() != null) {
- pdv.setFloat("latitude", (float) record.getLatitude());
- pdv.setFloat("longitude", (float) record.getLongitude());
- pdv.setFloat("elevation", record.getElevation());
- }
- if (record.getReportTime() != null) {
- pdv.setFloat("reportTime", record.getReportTime().floatValue());
- }
- if (record.getReceivedTime() != null) {
- pdv.setFloat("receivedTime", record.getReceivedTime().floatValue());
- }
- if (record.getStationId() != null) {
- pdv.setString("stationId", record.getStationId());
- }
- pdv.setLong("numericWMOid", record.getNumericWMOid());
- if (record.getBelowSurface() != null) {
- pdv.setFloat("belowSurfac", record.getBelowSurface());
- }
- if (record.getRiverStage() != null) {
- pdv.setFloat("riverStage", record.getRiverStage());
- }
- if (record.getPoolElevation() != null) {
- pdv.setFloat("poolElevation", record.getPoolElevation());
- }
- if (record.getTailwaterStage() != null) {
- pdv.setFloat("tailwaterStage", record.getTailwaterStage());
- }
- if (record.getRiverVelocity() != null) {
- pdv.setFloat("riverVelocity", record.getRiverVelocity());
- }
- if (record.getRiverInflow() != null) {
- pdv.setFloat("riverInflow", record.getRiverInflow());
- }
- if (record.getRiverFlow() != null) {
- pdv.setFloat("riverFlow", record.getRiverFlow());
- }
- if (record.getComputedOutflow() != null) {
- pdv.setFloat("computedOutflow", record.getComputedOutflow());
- }
- if (record.getWaterTemperature() != null) {
- pdv.setFloat("waterTemperature", record.getWaterTemperature());
- }
- if (record.getVoltageBattery() != null) {
- pdv.setFloat("voltageBattery", record.getVoltageBattery());
- }
- if (record.getWaterConductance() != null) {
- pdv.setFloat("waterConductance", record.getWaterConductance());
- }
- if (record.getWaterOxygen() != null) {
- pdv.setFloat("waterOxygen", record.getWaterConductance());
- }
- if (record.getWaterPH() != null) {
- pdv.setFloat("waterPH", record.getWaterPH());
- }
- if (record.getRelHumidity() != null) {
- pdv.setFloat("relHumidity", record.getRelHumidity());
- }
- if (record.getRiverReportChangeTime() != null) {
- pdv.setFloat("riverReportChangeTime",
- record.getRiverReportChangeTime().floatValue());
- }
- if (record.getTemperature() != null) {
- pdv.setFloat("temperature", record.getTemperature());
- }
- if (record.getDewpoint() != null) {
- pdv.setFloat("dewpoint", record.getDewpoint());
- }
- if (record.getWindDir() != null) {
- pdv.setFloat("windDir", record.getWindDir());
- }
- if (record.getWindSpeed() != null) {
- pdv.setFloat("windSpeed", record.getWindSpeed());
- }
- if (record.getWindSpeedPeak() != null) {
- pdv.setFloat("windSpeedPeak", record.getWindSpeedPeak());
- }
- if (record.getWindGust() != null) {
- pdv.setFloat("windGust", record.getWindGust().floatValue());
- }
- if (record.getPrecipAccum() != null) {
- pdv.setFloat("precipAccum", record.getPrecipAccum());
- }
- if (record.getPrecip5min() != null) {
- pdv.setFloat("precip5min", record.getPrecip5min());
- }
- if (record.getPrecip1hr() != null) {
- pdv.setFloat("precip1hr", record.getPrecip1hr());
- }
- if (record.getPrecip3hr() != null) {
- pdv.setFloat("precip3hr", record.getPrecip3hr());
- }
- if (record.getPrecip6hr() != null) {
- pdv.setFloat("precip6hr", record.getPrecip6hr());
- }
- if (record.getPrecip12hr() != null) {
- pdv.setFloat("precip12hr", record.getPrecip12hr());
- }
- if (record.getPrecip18hr() != null) {
- pdv.setFloat("precip18hr", record.getPrecip18hr());
- }
- if (record.getPrecip24hr() != null) {
- pdv.setFloat("precip24hr", record.getPrecip24hr());
- }
- return pdv;
- }
-}
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/distribution/ldadhydro.xml b/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/distribution/ldadhydro.xml
deleted file mode 100644
index 1143fae7a1..0000000000
--- a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/distribution/ldadhydro.xml
+++ /dev/null
@@ -1,29 +0,0 @@
-
-
-
-
-
- LDAD\.hydro\.*
-
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/purge/ldadhydroPurgeRules.xml b/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/purge/ldadhydroPurgeRules.xml
deleted file mode 100644
index f305712e99..0000000000
--- a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/utility/common_static/base/purge/ldadhydroPurgeRules.xml
+++ /dev/null
@@ -1,36 +0,0 @@
-
-
-
-
-
-
- 24
- =00-01:00:00
- 00-01:00:00
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.classpath b/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.classpath
deleted file mode 100644
index 1fa3e6803d..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.classpath
+++ /dev/null
@@ -1,7 +0,0 @@
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.project b/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.project
deleted file mode 100644
index e4513cbdd1..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-
-
- com.raytheon.uf.common.dataplugin.ldad
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/META-INF/MANIFEST.MF
deleted file mode 100644
index 79e7d3b670..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,13 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: LDAD Common
-Bundle-SymbolicName: com.raytheon.uf.common.dataplugin.ldad
-Bundle-Version: 1.18.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Export-Package: com.raytheon.uf.common.dataplugin.ldad
-Require-Bundle: javax.persistence,
- com.raytheon.uf.common.dataplugin,
- com.raytheon.uf.common.pointdata
-Import-Package: com.raytheon.uf.common.geospatial,
- com.raytheon.uf.common.serialization.annotations
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/build.properties b/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/build.properties
deleted file mode 100644
index 34d2e4d2da..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/build.properties
+++ /dev/null
@@ -1,4 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- .
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/src/com/raytheon/uf/common/dataplugin/ldad/LdadRecord.java b/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/src/com/raytheon/uf/common/dataplugin/ldad/LdadRecord.java
deleted file mode 100644
index 64945d5bf0..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldad/src/com/raytheon/uf/common/dataplugin/ldad/LdadRecord.java
+++ /dev/null
@@ -1,126 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-package com.raytheon.uf.common.dataplugin.ldad;
-
-import java.util.Date;
-
-import javax.persistence.MappedSuperclass;
-import javax.persistence.SequenceGenerator;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.persist.PersistablePluginDataObject;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
-
-/**
- * Abstract base class for LDAD records
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------- -------- --------- -----------------
- * Mar 06, 2018 6851 randerso Initial creation
- * Apr 24, 2019 6140 tgurney Remove Inheritance annotation
- * (Hibernate 5.4 fix)
- *
- *
- *
- * @author randerso
- */
-
-@MappedSuperclass
-@SequenceGenerator(name = PluginDataObject.ID_GEN)
-@DynamicSerialize
-public abstract class LdadRecord extends PersistablePluginDataObject {
- private static final long serialVersionUID = 1L;
-
- /*
- * TODO: move common fields from MesonetLdadRecord and HydroLdadRecord up to
- * LdadRecord. Unfortunately this changes the dataURI so would require
- * additional changes.
- */
-
- /**
- * Default Constructor
- */
- public LdadRecord() {
- super();
- }
-
- /**
- * Constructor for DataURI construction through base class. This is used by
- * the notification service.
- *
- * @param uri
- * A data uri applicable to this class.
- */
- public LdadRecord(String uri) {
- super(uri);
- }
-
- /**
- * @param dataProvider
- * the dataProvider to set
- */
- public abstract void setDataProvider(String dataProvider);
-
- /**
- * @param stationType
- * the stationType to set
- */
- public abstract void setStationType(String stationType);
-
- /**
- * @param reportTime
- * the reportTime to set
- */
- public abstract void setReportTime(long reportTime);
-
- /**
- * @return the observationTime
- */
- public abstract Date getObservationTime();
-
- /**
- * @param observationTime
- * the observationTime to set
- */
- public abstract void setObservationTime(Date observationTime);
-
- /**
- * @param location
- * the location to set
- */
- public abstract void setLocation(SurfaceObsLocation location);
-
- /**
- * @param rawMessage
- * the rawMessage to set
- */
- public abstract void setRawMessage(String rawMessage);
-
- /**
- * @return record as rawMessage
- */
- public abstract String toMessage();
-
-}
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.classpath b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.classpath
deleted file mode 100644
index ad32c83a78..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.classpath
+++ /dev/null
@@ -1,7 +0,0 @@
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.project b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.project
deleted file mode 100644
index 2b71da2839..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-
-
- com.raytheon.uf.common.dataplugin.ldadhydro
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/META-INF/MANIFEST.MF
deleted file mode 100644
index 8606e67731..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,15 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: Ldadhydro
-Bundle-SymbolicName: com.raytheon.uf.common.dataplugin.ldadhydro
-Bundle-Version: 1.19.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Import-Package: com.raytheon.uf.common.geospatial,
- com.raytheon.uf.common.serialization.annotations,
- org.locationtech.jts.geom
-Export-Package: com.raytheon.uf.common.dataplugin.ldadhydro
-Require-Bundle: javax.persistence,
- com.raytheon.uf.common.dataplugin,
- com.raytheon.uf.common.pointdata,
- com.raytheon.uf.common.dataplugin.ldad
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/build.properties b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/build.properties
deleted file mode 100644
index 544aa7de88..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/build.properties
+++ /dev/null
@@ -1,5 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- .,\
- utility/
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/com.raytheon.uf.common.dataplugin.ldadhydro.ecl b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/com.raytheon.uf.common.dataplugin.ldadhydro.ecl
deleted file mode 100644
index e69de29bb2..0000000000
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/src/com/raytheon/uf/common/dataplugin/ldadhydro/HydroLdadRecord.java b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/src/com/raytheon/uf/common/dataplugin/ldadhydro/HydroLdadRecord.java
deleted file mode 100644
index 9b66ebd83e..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/src/com/raytheon/uf/common/dataplugin/ldadhydro/HydroLdadRecord.java
+++ /dev/null
@@ -1,1036 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-package com.raytheon.uf.common.dataplugin.ldadhydro;
-
-import java.util.Date;
-
-import javax.persistence.Access;
-import javax.persistence.AccessType;
-import javax.persistence.Column;
-import javax.persistence.Embedded;
-import javax.persistence.Entity;
-import javax.persistence.SequenceGenerator;
-import javax.persistence.Table;
-import javax.persistence.UniqueConstraint;
-
-import org.hibernate.annotations.Index;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.annotations.DataURI;
-import com.raytheon.uf.common.dataplugin.ldad.LdadRecord;
-import com.raytheon.uf.common.dataplugin.persist.IPersistable;
-import com.raytheon.uf.common.geospatial.ISpatialEnabled;
-import com.raytheon.uf.common.pointdata.IPointData;
-import com.raytheon.uf.common.pointdata.PointDataView;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
-import org.locationtech.jts.geom.Geometry;
-
-/**
- * Record implementation for ldadhydro plugin.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------- -------- --------- --------------------------------------------
- * Sep 30, 2009 vkorolev Initial creation
- * Apr 04, 2013 1846 bkowal Added an index on refTime and forecastTime
- * Apr 12, 2013 1857 bgonzale Added SequenceGenerator annotation.
- * May 07, 2013 1869 bsteffen Remove dataURI column from PluginDataObject.
- * Aug 30, 2013 2298 rjpeter Make getPluginName abstract
- * Oct 15, 2013 2361 njensen Remove XML annotations and IDecoderGettable
- * Jul 23, 2015 2360 rferrel Add name to unique constraint.
- * Mar 06, 2018 6851 randerso Changed to extend LdadRecord. Code cleanup.
- *
- *
- *
- * @author vkorolev
- */
-
-@Entity
-@SequenceGenerator(initialValue = 1, name = PluginDataObject.ID_GEN, sequenceName = "ldadhydroseq")
-@Table(name = "ldadhydro", uniqueConstraints = {
- @UniqueConstraint(name = "uk_ldadhydro_datauri_fields", columnNames = {
- "dataURI" }) })
-/*
- * Both refTime and forecastTime are included in the refTimeIndex since
- * forecastTime is unlikely to be used.
- */
-@org.hibernate.annotations.Table(appliesTo = "ldadhydro", indexes = {
- @Index(name = "ldadhydro_refTimeIndex", columnNames = { "refTime",
- "forecastTime" }) })
-@DynamicSerialize
-public class HydroLdadRecord extends LdadRecord
- implements ISpatialEnabled, IPointData, IPersistable {
-
- private static final long serialVersionUID = 1L;
-
- // TODO: move common fields from MesonetLdadRecord and HydroLdadRecord up to
- // LdadRecord. Unfortunately this changes the dataURI so would require
- // additional changes.
-
- // Time of the observation.
- @DataURI(position = 2)
- @Column
- @DynamicSerializeElement
- private Date observationTime;
-
- // numeric WMO identification number
- @Column
- @DynamicSerializeElement
- private long numericWMOid;
-
- // latitude, longitude, elevation, stationId="RALC2"
- @Embedded
- @DataURI(position = 3, embedded = true)
- @DynamicSerializeElement
- private SurfaceObsLocation location;
-
- // Data Provider station Id
- @Column
- @DynamicSerializeElement
- private String providerId;
-
- // Alphanumeric station name
- @Column
- @DynamicSerializeElement
- private String stationName;
-
- // Handbook Id (AFOS id or SHEF id)
- @Column
- @DynamicSerializeElement
- private String handbook5Id;
-
- // Home WFO Id for the LDAD data
- @Column
- @DynamicSerializeElement
- private String homeWFO;
-
- // LDAD hydro station type.
- @Column
- @DynamicSerializeElement
- private String stationType;
-
- // LDAD hydro data provider
- @DataURI(position = 1)
- @Column
- @DynamicSerializeElement
- private String dataProvider;
-
- // Date and time data was processed by the data provider (e.g ALERT)
- // seconds since epoch
- @Column
- @DynamicSerializeElement
- private double reportTime;
-
- // Date and time the data was received
- // seconds since epoch
- @Column
- @DynamicSerializeElement
- private Double receivedTime;
-
- // Below surface - meters
- @Column
- @DynamicSerializeElement
- private Float belowSurface;
-
- // River stage - meters
- @Column
- @DynamicSerializeElement
- private Float riverStage;
-
- // Pool elevation - meters
- @Column
- @DynamicSerializeElement
- private Float poolElevation;
-
- // Tail water stage - meters
- @Column
- @DynamicSerializeElement
- private Float tailwaterStage;
-
- // River velocity - kph
- @Column
- @DynamicSerializeElement
- private Float riverVelocity;
-
- // River inflow - meter^3 / sec
- @Column
- @DynamicSerializeElement
- private Float riverInflow;
-
- // River flow - meter^3 / sec
- @Column
- @DynamicSerializeElement
- private Float riverFlow;
-
- // Computed outflow - meter^3 / sec
- @Column
- @DynamicSerializeElement
- private Float computedOutflow;
-
- // Water temperature - kelvin
- @Column
- @DynamicSerializeElement
- private Float waterTemperature;
-
- // Battery voltage - volt
- @Column
- @DynamicSerializeElement
- private Float voltageBattery;
-
- // Water conductance - umhos/cm
- @Column
- @DynamicSerializeElement
- private Float waterConductance;
-
- // Water oxygen - mg/l
- @Column
- @DynamicSerializeElement
- private Float waterOxygen;
-
- // Water PH - pH
- @Column
- @DynamicSerializeElement
- private Float waterPH;
-
- // Relative humidity
- @Column
- @DynamicSerializeElement
- private Float relHumidity;
-
- // River stage & flow - time of last change (ALERT)
- // seconds since epoch
- @Column
- @DynamicSerializeElement
- private Double riverReportChangeTime;
-
- // Observation air temperature in degrees Kelvin.
- @Column
- @DynamicSerializeElement
- private Float temperature;
-
- // Observation dewpoint temperature in degrees Kelvin.
- @Column
- @DynamicSerializeElement
- private Float dewpoint;
-
- // Observation wind direction in angular degrees.
- @Column
- @DynamicSerializeElement
- private Float windDir;
-
- // Observation wind speed in meters per second.
- @Column
- @DynamicSerializeElement
- private Float windSpeed;
-
- // Wind speed peak
- @Column
- @DynamicSerializeElement
- private Float windSpeedPeak;
-
- // Observation wind gust in meters per second.
- @Column
- @DynamicSerializeElement
- private Double windGust;
-
- // precip accumulation with an unknown time period - mm.
- @Column
- @DynamicSerializeElement
- private Float precipAccum;
-
- // 5 minute precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip5min;
-
- // 1 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip1hr;
-
- // 3 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip3hr;
-
- // 6 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip6hr;
-
- // 12 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip12hr;
-
- // 18 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip18hr;
-
- // 24 hour precip accumulation - mm
- @Column
- @DynamicSerializeElement
- private Float precip24hr;
-
- // Raw text LDAD hydro report
- @Column
- @DynamicSerializeElement
- private String rawMessage;
-
- private PointDataView pointDataView;
-
- /**
- *
- */
- public HydroLdadRecord() {
- }
-
- /**
- * Constructor for DataURI construction through base class. This is used by
- * the notification service.
- *
- * @param uri
- * A data uri applicable to this class.
- */
- public HydroLdadRecord(String uri) {
- super(uri);
- }
-
- /**
- * Get this observation's geometry.
- *
- * @return The geometry for this observation.
- */
- public Geometry getGeometry() {
- return location.getGeometry();
- }
-
- /**
- * Get the geometry latitude.
- *
- * @return The geometry latitude.
- */
- public double getLatitude() {
- return location.getLatitude();
- }
-
- /**
- * Get the geometry longitude.
- *
- * @return The geometry longitude.
- */
- public double getLongitude() {
- return location.getLongitude();
- }
-
- /**
- * Get the station identifier for this observation.
- *
- * @return the stationId
- */
- public String getStationId() {
- return location.getStationId();
- }
-
- /**
- * Get the elevation, in meters, of the observing platform or location.
- *
- * @return The observation elevation, in meters.
- */
- public Integer getElevation() {
- return location.getElevation();
- }
-
- /**
- * @return the location
- */
- public SurfaceObsLocation getLocation() {
- return location;
- }
-
- /**
- * @param location
- * the location to set
- */
- @Override
- public void setLocation(SurfaceObsLocation location) {
- this.location = location;
- }
-
- /**
- * @return the timeObs
- */
- @Override
- public Date getObservationTime() {
- return observationTime;
- }
-
- /**
- * @param observationTime
- * the observationTime to set
- */
- @Override
- public void setObservationTime(Date observationTime) {
- this.observationTime = observationTime;
- }
-
- /**
- * @return the windSpeed
- */
- public Float getWindSpeed() {
- return windSpeed;
- }
-
- /**
- * @param windSpeed
- * the windSpeed to set
- */
- public void setWindSpeed(Float windSpeed) {
- this.windSpeed = windSpeed;
- }
-
- /**
- * @return the windGust
- */
- public Double getWindGust() {
- return windGust;
- }
-
- /**
- * @param windGust
- * the windGust to set
- */
- public void setWindGust(Double windGust) {
- this.windGust = windGust;
- }
-
- /**
- * @param location
- * the spatial object to set
- */
- public void setSpatialObject(SurfaceObsLocation location) {
- this.location = location;
- }
-
- /**
- *
- */
- @Override
- public SurfaceObsLocation getSpatialObject() {
- return location;
- }
-
- /**
- *
- * @param providerId
- * the providerId to set
- */
- public void setProviderId(String providerId) {
- this.providerId = providerId;
- }
-
- /**
- * @return the providerId
- */
- public String getProviderId() {
- return providerId;
- }
-
- /**
- * @param stationName
- * the stationName to set
- */
- public void setStationName(String stationName) {
- this.stationName = stationName;
- }
-
- /**
- * @return the stationName
- */
- public String getStationName() {
- return stationName;
- }
-
- /**
- * @param handbook5Id
- * the handbook5Id to set
- */
- public void setHandbook5Id(String handbook5Id) {
- this.handbook5Id = handbook5Id;
- }
-
- /**
- * @return the handbook5Id
- */
- public String getHandbook5Id() {
- return handbook5Id;
- }
-
- /**
- * @param homeWFO
- * the homeWFO to set
- */
- public void setHomeWFO(String homeWFO) {
- this.homeWFO = homeWFO;
- }
-
- /**
- * @return the homeWFO
- */
- public String getHomeWFO() {
- return homeWFO;
- }
-
- /**
- * @param stationType
- * the stationType to set
- */
- @Override
- public void setStationType(String stationType) {
- this.stationType = stationType;
- }
-
- /**
- * @return the stationType
- */
- public String getStationType() {
- return stationType;
- }
-
- /**
- * @param dataProvider
- * the dataProvider to set
- */
- @Override
- public void setDataProvider(String dataProvider) {
- this.dataProvider = dataProvider;
- }
-
- /**
- * @return the dataProvider
- */
- public String getDataProvider() {
- return dataProvider;
- }
-
- /**
- * @param receivedTime
- * the receivedTime to set
- */
- public void setReceivedTime(Double receivedTime) {
- this.receivedTime = receivedTime;
- }
-
- /**
- * @return the receivedTime
- */
- public Double getReceivedTime() {
- return receivedTime;
- }
-
- /**
- * @param belowSurface
- * the belowSurface to set
- */
- public void setBelowSurface(Float belowSurface) {
- this.belowSurface = belowSurface;
- }
-
- /**
- * @return the belowSurface
- */
- public Float getBelowSurface() {
- return belowSurface;
- }
-
- /**
- * @param riverStage
- * the riverStage to set
- */
- public void setRiverStage(Float riverStage) {
- this.riverStage = riverStage;
- }
-
- /**
- * @return the riverStage
- */
- public Float getRiverStage() {
- return riverStage;
- }
-
- /**
- * @param poolElevation
- * the poolElevation to set
- */
- public void setPoolElevation(Float poolElevation) {
- this.poolElevation = poolElevation;
- }
-
- /**
- * @return the poolElevation
- */
- public Float getPoolElevation() {
- return poolElevation;
- }
-
- /**
- * @param tailwaterStage
- * the tailwaterStage to set
- */
- public void setTailwaterStage(Float tailwaterStage) {
- this.tailwaterStage = tailwaterStage;
- }
-
- /**
- * @return the tailwaterStage
- */
- public Float getTailwaterStage() {
- return tailwaterStage;
- }
-
- /**
- * @param riverVelocity
- * the riverVelocity to set
- */
- public void setRiverVelocity(Float riverVelocity) {
- this.riverVelocity = riverVelocity;
- }
-
- /**
- * @return the riverVelocity
- */
- public Float getRiverVelocity() {
- return riverVelocity;
- }
-
- /**
- * @param riverInflow
- * the riverInflow to set
- */
- public void setRiverInflow(Float riverInflow) {
- this.riverInflow = riverInflow;
- }
-
- /**
- * @return the riverInflow
- */
- public Float getRiverInflow() {
- return riverInflow;
- }
-
- /**
- * @param riverFlow
- * the riverFlow to set
- */
- public void setRiverFlow(Float riverFlow) {
- this.riverFlow = riverFlow;
- }
-
- /**
- * @return the riverFlow
- */
- public Float getRiverFlow() {
- return riverFlow;
- }
-
- /**
- * @param computedOutflow
- * the computedOutflow to set
- */
- public void setComputedOutflow(Float computedOutflow) {
- this.computedOutflow = computedOutflow;
- }
-
- /**
- * @return the computedOutflow
- */
- public Float getComputedOutflow() {
- return computedOutflow;
- }
-
- /**
- * @param waterTemperature
- * the waterTemperature to set
- */
- public void setWaterTemperature(Float waterTemperature) {
- this.waterTemperature = waterTemperature;
- }
-
- /**
- * @return the waterTemperature
- */
- public Float getWaterTemperature() {
- return waterTemperature;
- }
-
- /**
- * @param voltageBattery
- * the voltageBattery to set
- */
- public void setVoltageBattery(Float voltageBattery) {
- this.voltageBattery = voltageBattery;
- }
-
- /**
- * @return the voltageBattery
- */
- public Float getVoltageBattery() {
- return voltageBattery;
- }
-
- /**
- * @param waterConductance
- * the waterConductance to set
- */
- public void setWaterConductance(Float waterConductance) {
- this.waterConductance = waterConductance;
- }
-
- /**
- * @return the waterConductance
- */
- public Float getWaterConductance() {
- return waterConductance;
- }
-
- /**
- * @param waterOxygen
- * the waterOxygen to set
- */
- public void setWaterOxygen(Float waterOxygen) {
- this.waterOxygen = waterOxygen;
- }
-
- /**
- * @return the waterOxygen
- */
- public Float getWaterOxygen() {
- return waterOxygen;
- }
-
- /**
- * @param waterPH
- * the waterPH to set
- */
- public void setWaterPH(Float waterPH) {
- this.waterPH = waterPH;
- }
-
- /**
- * @return the waterPH
- */
- public Float getWaterPH() {
- return waterPH;
- }
-
- /**
- * @param riverReportChangeTime
- * the riverReportChangeTime to set
- */
- public void setRiverReportChangeTime(Double riverReportChangeTime) {
- this.riverReportChangeTime = riverReportChangeTime;
- }
-
- /**
- * @return the riverReportChangeTime
- */
- public Double getRiverReportChangeTime() {
- return riverReportChangeTime;
- }
-
- /**
- * @param precip12hr
- * the precip12hr to set
- */
- public void setPrecip12hr(Float precip12hr) {
- this.precip12hr = precip12hr;
- }
-
- /**
- * @return the precip12hr
- */
- public Float getPrecip12hr() {
- return precip12hr;
- }
-
- /**
- * @param precip18hr
- * the precip18hr to set
- */
- public void setPrecip18hr(Float precip18hr) {
- this.precip18hr = precip18hr;
- }
-
- /**
- * @return the precip18hr
- */
- public Float getPrecip18hr() {
- return precip18hr;
- }
-
- /**
- * @param temperature
- * the temperature to set
- */
- public void setTemperature(Float temperature) {
- this.temperature = temperature;
- }
-
- /**
- * @return the temperature
- */
- public Float getTemperature() {
- return temperature;
- }
-
- /**
- * @param dewpoint
- * the dewpoint to set
- */
- public void setDewpoint(Float dewpoint) {
- this.dewpoint = dewpoint;
- }
-
- /**
- * @return the dewpoint
- */
- public Float getDewpoint() {
- return dewpoint;
- }
-
- /**
- * @param windDir
- * the windDir to set
- */
- public void setWindDir(Float windDir) {
- this.windDir = windDir;
- }
-
- /**
- * @return the windDir
- */
- public Float getWindDir() {
- return windDir;
- }
-
- /**
- * @param windSpeedPeak
- * the windSpeedPeak to set
- */
- public void setWindSpeedPeak(Float windSpeedPeak) {
- this.windSpeedPeak = windSpeedPeak;
- }
-
- /**
- * @return the windSpeedPeak
- */
- public Float getWindSpeedPeak() {
- return windSpeedPeak;
- }
-
- /**
- * @param precipAccum
- * the precipAccum to set
- */
- public void setPrecipAccum(Float precipAccum) {
- this.precipAccum = precipAccum;
- }
-
- /**
- * @return the precipAccum
- */
- public Float getPrecipAccum() {
- return precipAccum;
- }
-
- /**
- * @param precip5min
- * the precip5min to set
- */
- public void setPrecip5min(Float precip5min) {
- this.precip5min = precip5min;
- }
-
- /**
- * @return the precip5min
- */
- public Float getPrecip5min() {
- return precip5min;
- }
-
- /**
- * @param precip1hr
- * the precip1hr to set
- */
- public void setPrecip1hr(Float precip1hr) {
- this.precip1hr = precip1hr;
- }
-
- /**
- * @return the precip1hr
- */
- public Float getPrecip1hr() {
- return precip1hr;
- }
-
- /**
- * @param precip3hr
- * the precip3hr to set
- */
- public void setPrecip3hr(Float precip3hr) {
- this.precip3hr = precip3hr;
- }
-
- /**
- * @return the precip3hr
- */
- public Float getPrecip3hr() {
- return precip3hr;
- }
-
- /**
- * @param precip6hr
- * the precip6hr to set
- */
- public void setPrecip6hr(Float precip6hr) {
- this.precip6hr = precip6hr;
- }
-
- /**
- * @return the precip6hr
- */
- public Float getPrecip6hr() {
- return precip6hr;
- }
-
- /**
- * @param precip24hr
- * the precip24hr to set
- */
- public void setPrecip24hr(Float precip24hr) {
- this.precip24hr = precip24hr;
- }
-
- /**
- * @return the precip24hr
- */
- public Float getPrecip24hr() {
- return precip24hr;
- }
-
- /**
- * @param rawMessage
- * the rawMessage to set
- */
- @Override
- public void setRawMessage(String rawMessage) {
- this.rawMessage = rawMessage;
- }
-
- /**
- * @return the rawMessage
- */
- public String getRawMessage() {
- return rawMessage;
- }
-
- /**
- * @param relHumidity
- * the relHumidity to set
- */
- public void setRelHumidity(Float relHumidity) {
- this.relHumidity = relHumidity;
- }
-
- /**
- * @return the relHumidity
- */
- public Float getRelHumidity() {
- return relHumidity;
- }
-
- /**
- * @param numericWMOid
- * the numericWMOid to set
- */
- public void setNumericWMOid(long numericWMOid) {
- this.numericWMOid = numericWMOid;
- }
-
- /**
- * @return the numericWMOid
- */
- public long getNumericWMOid() {
- return numericWMOid;
- }
-
- /**
- * @param reportTime
- * the reportTime to set
- */
- @Override
- public void setReportTime(long reportTime) {
- this.reportTime = reportTime;
- }
-
- /**
- * @return the reportTime
- */
- public Double getReportTime() {
- return reportTime;
- }
-
- @Override
- public void setPointDataView(PointDataView pointDataView) {
- this.pointDataView = pointDataView;
-
- }
-
- /**
- * @return the pointDataView
- */
- @Override
- public PointDataView getPointDataView() {
- return this.pointDataView;
- }
-
- @Override
- @Column
- @Access(AccessType.PROPERTY)
- public String getDataURI() {
- return super.getDataURI();
- }
-
- @Override
- public String toMessage() {
- return null;
- }
-
- @Override
- public String getPluginName() {
- return "ldadhydro";
- }
-}
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip15min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip15min.xml
deleted file mode 100644
index 74d8a6d347..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip15min.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip30min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip30min.xml
deleted file mode 100644
index b159a6b669..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precip30min.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum15min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum15min.xml
deleted file mode 100644
index d6b9c2b800..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum15min.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum1hr.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum1hr.xml
deleted file mode 100644
index 089761e848..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum1hr.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum30min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum30min.xml
deleted file mode 100644
index 65a8feeb9d..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum30min.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum3hr.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum3hr.xml
deleted file mode 100644
index c1313e7e0c..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum3hr.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum5min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum5min.xml
deleted file mode 100644
index c95905e8d2..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/accum_precipAccum5min.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip15min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip15min.xml
deleted file mode 100644
index de35d5d558..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip15min.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip1hr.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip1hr.xml
deleted file mode 100644
index f1986cfb6e..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip1hr.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip30min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip30min.xml
deleted file mode 100644
index 15f3e013ad..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip30min.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip3hr.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip3hr.xml
deleted file mode 100644
index 096beb44d0..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip3hr.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip5min.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip5min.xml
deleted file mode 100644
index 0d5d63c402..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadhydro/utility/common_static/base/derivedParameters/definitions/lh_precip5min.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.classpath b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.classpath
deleted file mode 100644
index 1fa3e6803d..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.classpath
+++ /dev/null
@@ -1,7 +0,0 @@
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.project b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.project
deleted file mode 100644
index 825bff20ee..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-
-
- com.raytheon.uf.common.dataplugin.ldadmesonet
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/META-INF/MANIFEST.MF
deleted file mode 100644
index 83534dfaff..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,16 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: Ldadmesonet Plug-in
-Bundle-SymbolicName: com.raytheon.uf.common.dataplugin.ldadmesonet
-Bundle-Version: 1.18.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Import-Package: com.raytheon.uf.common.geospatial,
- com.raytheon.uf.common.serialization.annotations,
- org.locationtech.jts.geom
-Export-Package: com.raytheon.uf.common.dataplugin.ldadmesonet
-Require-Bundle: javax.persistence,
- com.raytheon.uf.common.dataplugin,
- com.raytheon.uf.common.pointdata,
- com.raytheon.uf.common.dataaccess,
- com.raytheon.uf.common.dataplugin.ldad
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/build.properties b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/build.properties
deleted file mode 100644
index 5791d48d5f..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/build.properties
+++ /dev/null
@@ -1,5 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- .,\
- res/
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/com.raytheon.uf.common.dataplugin.ldadmesonet.ecl b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/com.raytheon.uf.common.dataplugin.ldadmesonet.ecl
deleted file mode 100644
index e69de29bb2..0000000000
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/res/spring/ldadmesonet-common-dataaccess.xml b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/res/spring/ldadmesonet-common-dataaccess.xml
deleted file mode 100644
index 69f17e7af8..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/res/spring/ldadmesonet-common-dataaccess.xml
+++ /dev/null
@@ -1,13 +0,0 @@
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/src/com/raytheon/uf/common/dataplugin/ldadmesonet/MesonetLdadRecord.java b/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/src/com/raytheon/uf/common/dataplugin/ldadmesonet/MesonetLdadRecord.java
deleted file mode 100644
index 6b02d51fd3..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.ldadmesonet/src/com/raytheon/uf/common/dataplugin/ldadmesonet/MesonetLdadRecord.java
+++ /dev/null
@@ -1,1701 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-package com.raytheon.uf.common.dataplugin.ldadmesonet;
-
-import java.util.Date;
-
-import javax.persistence.Column;
-import javax.persistence.Embedded;
-import javax.persistence.Entity;
-import javax.persistence.SequenceGenerator;
-import javax.persistence.Table;
-import javax.persistence.Transient;
-import javax.persistence.UniqueConstraint;
-
-import org.hibernate.annotations.Index;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.annotations.DataURI;
-import com.raytheon.uf.common.dataplugin.annotations.NullString;
-import com.raytheon.uf.common.dataplugin.ldad.LdadRecord;
-import com.raytheon.uf.common.dataplugin.persist.IPersistable;
-import com.raytheon.uf.common.geospatial.ISpatialEnabled;
-import com.raytheon.uf.common.pointdata.IPointData;
-import com.raytheon.uf.common.pointdata.PointDataView;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
-import org.locationtech.jts.geom.Geometry;
-
-/**
- * Record implementation for ldadmesonet plugin.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------- -------- --------- --------------------------------------------
- * Sep 04, 2009 vkorolev Initial creation
- * Apr 04, 2013 1846 bkowal Added an index on refTime and forecastTime
- * Apr 12, 2013 1857 bgonzale Added SequenceGenerator annotation.
- * May 07, 2013 1869 bsteffen Remove dataURI column from PluginDataObject.
- * May 15, 2013 1869 bsteffen Remove DataURI column from ldadmesonet.
- * Aug 30, 2013 2298 rjpeter Make getPluginName abstract
- * Jul 20, 2015 4360 rferrel Named unique constraint Made reportType and
- * dataProvider not nullable
- * Mar 06, 2018 6851 randerso Changed to extend LdadRecord. Code cleanup.
- * May 10, 2018 7288 randerso Removed unused and unimplemented
- * setStationId() method
- *
- *
- *
- * @author vkorolev
- */
-
-@Entity
-@SequenceGenerator(initialValue = 1, name = PluginDataObject.ID_GEN, sequenceName = "ldadmesonetseq")
-@Table(name = "ldadmesonet", uniqueConstraints = {
- @UniqueConstraint(name = "uk_ldadmesonet_datauri_fields", columnNames = {
- "stationid", "reftime", "reporttype", "dataprovider",
- "latitude", "longitude" }) })
-/*
- * Both refTime and forecastTime are included in the refTimeIndex since
- * forecastTime is unlikely to be used.
- */
-@org.hibernate.annotations.Table(appliesTo = "ldadmesonet", indexes = {
- @Index(name = "ldadmesonet_refTimeIndex", columnNames = { "refTime",
- "forecastTime" }) })
-@DynamicSerialize
-public class MesonetLdadRecord extends LdadRecord
- implements ISpatialEnabled, IPointData, IPersistable {
-
- private static final long serialVersionUID = 1L;
-
- private static final String OBS_TIME_FMT = "%1$tY/%
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/.project b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/.project
deleted file mode 100644
index 8104b96273..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-
-
- com.raytheon.uf.common.dataplugin.qc
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
-
-
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/META-INF/MANIFEST.MF
deleted file mode 100644
index 23f50943b0..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,15 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: Qc Plug-in
-Bundle-SymbolicName: com.raytheon.uf.common.dataplugin.qc
-Bundle-Version: 1.18.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Require-Bundle: com.raytheon.uf.common.dataplugin,
- com.raytheon.uf.common.pointdata
-Export-Package: com.raytheon.uf.common.dataplugin.qc
-Import-Package: com.raytheon.uf.common.geospatial,
- com.raytheon.uf.common.pointdata.spatial,
- com.raytheon.uf.common.serialization.annotations,
- com.raytheon.uf.common.status,
- javax.persistence
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/build.properties b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/build.properties
deleted file mode 100644
index 34d2e4d2da..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/build.properties
+++ /dev/null
@@ -1,4 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- .
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/com.raytheon.uf.common.dataplugin.qc.ecl b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/com.raytheon.uf.common.dataplugin.qc.ecl
deleted file mode 100644
index e69de29bb2..0000000000
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/resources/com.raytheon.uf.common.dataplugin.qc.properties b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/resources/com.raytheon.uf.common.dataplugin.qc.properties
deleted file mode 100644
index b9b97f0ee2..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/resources/com.raytheon.uf.common.dataplugin.qc.properties
+++ /dev/null
@@ -1 +0,0 @@
-HDF5_PATH=hdf5/QC
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/src/com/raytheon/uf/common/dataplugin/qc/QCRecord.java b/edexOsgi/com.raytheon.uf.common.dataplugin.qc/src/com/raytheon/uf/common/dataplugin/qc/QCRecord.java
deleted file mode 100644
index 8ae570c02a..0000000000
--- a/edexOsgi/com.raytheon.uf.common.dataplugin.qc/src/com/raytheon/uf/common/dataplugin/qc/QCRecord.java
+++ /dev/null
@@ -1,193 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-
-package com.raytheon.uf.common.dataplugin.qc;
-
-import javax.persistence.Column;
-import javax.persistence.Embedded;
-import javax.persistence.Entity;
-import javax.persistence.SequenceGenerator;
-import javax.persistence.Table;
-import javax.persistence.UniqueConstraint;
-
-import org.hibernate.annotations.Index;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.annotations.DataURI;
-import com.raytheon.uf.common.dataplugin.annotations.NullString;
-import com.raytheon.uf.common.dataplugin.persist.PersistablePluginDataObject;
-import com.raytheon.uf.common.geospatial.ISpatialEnabled;
-import com.raytheon.uf.common.geospatial.ISpatialObject;
-import com.raytheon.uf.common.pointdata.IPointData;
-import com.raytheon.uf.common.pointdata.PointDataView;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
-import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
-
-/**
- * Record class for QC data
- *
- *
- *
- * SOFTWARE HISTORY
- * Date Ticket# Engineer Description
- * ------------ ---------- ----------- --------------------------
- * Dec 07, 2009 3408 bphillip Initial creation
- * Apr 04, 2013 1846 bkowal Added an index on refTime and
- * forecastTime
- * Apr 12, 2013 1857 bgonzale Added SequenceGenerator annotation.
- * May 07, 2013 1869 bsteffen Remove dataURI column from
- * PluginDataObject.
- * May 16, 2013 1869 bsteffen Remove DataURI column from qc.
- * Aug 30, 2013 2298 rjpeter Make getPluginName abstract
- * Feb 27, 2014 2852 rferrel Add getter/setter to FakePointDataView.
- * Jul 21, 2015 4360 rferrel Named unique constraint.
- * Jan 04, 2018 6861 njensen Removed unnecessary fields, use PointDataView
- *
- *
- *
- *
- * @author bphillip
- */
-@Entity
-@SequenceGenerator(initialValue = 1, name = PluginDataObject.ID_GEN, sequenceName = "qcseq")
-@Table(name = "qc", uniqueConstraints = { @UniqueConstraint(name = "uk_qc_datauri_fields", columnNames = {
- "stationid", "reftime", "qcType", "latitude", "longitude" }) })
-/*
- * Both refTime and forecastTime are included in the refTimeIndex since
- * forecastTime is unlikely to be used.
- */
-@org.hibernate.annotations.Table(appliesTo = "qc", indexes = { @Index(name = "qc_refTimeIndex", columnNames = {
- "refTime", "forecastTime" }) })
-@DynamicSerialize
-public class QCRecord extends PersistablePluginDataObject
- implements ISpatialEnabled, IPointData {
-
- private static final long serialVersionUID = -8836262244188895665L;
-
- @Embedded
- @DataURI(position = 2, embedded = true)
- @DynamicSerializeElement
- private SurfaceObsLocation location;
-
- @Column(nullable = false, length = 20)
- @DataURI(position = 1)
- @NullString
- @DynamicSerializeElement
- private String qcType;
-
- @Column(length = 15)
- private String ncSet;
-
- private PointDataView pointDataView;
-
- public QCRecord() {
-
- }
-
- public QCRecord(String uri) {
- super(uri);
- }
-
- public String getStationId() {
- return location.getStationId();
- }
- /**
- * @return the location
- */
- public SurfaceObsLocation getLocation() {
- return location;
- }
-
- /**
- * @param location
- * the location to set
- */
- public void setLocation(SurfaceObsLocation location) {
- this.location = location;
- }
-
- public float getLatitude() {
- return location.getLatitude().floatValue();
- }
-
- public float getLongitude() {
- return location.getLongitude().floatValue();
- }
-
- public float getElevation() {
- return location.getElevation();
- }
-
- public static long getSerialVersionUID() {
- return serialVersionUID;
- }
-
- /**
- * @return the ncSet
- */
- public String getNcSet() {
- return ncSet;
- }
-
- /**
- * @param ncSet
- * the ncSet to set
- */
- public void setNcSet(String ncSet) {
- this.ncSet = ncSet;
- }
-
- @Override
- public ISpatialObject getSpatialObject() {
- return location;
- }
-
- /**
- * @return the qcType
- */
- public String getQcType() {
- return qcType;
- }
-
- /**
- * @param qcType
- * the qcType to set
- */
- public void setQcType(String qcType) {
- this.qcType = qcType;
- }
-
- @Override
- public PointDataView getPointDataView() {
- return pointDataView;
- }
-
- @Override
- public void setPointDataView(PointDataView pointDataView) {
- this.pointDataView = pointDataView;
- }
-
- @Override
- public String getPluginName() {
- return "qc";
- }
-
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.dataplugins.feature/feature.xml b/edexOsgi/com.raytheon.uf.edex.dataplugins.feature/feature.xml
index 50c2a66bf2..2984494bb6 100644
--- a/edexOsgi/com.raytheon.uf.edex.dataplugins.feature/feature.xml
+++ b/edexOsgi/com.raytheon.uf.edex.dataplugins.feature/feature.xml
@@ -45,41 +45,13 @@
version="0.0.0"
unpack="false"/>
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/.project b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/.project
deleted file mode 100644
index 8b8354367c..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-
-
- com.raytheon.uf.edex.plugin.ldadmesonet
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/META-INF/MANIFEST.MF
deleted file mode 100644
index 54dbeb466f..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,12 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: Ldadmesonet Plug-in
-Bundle-SymbolicName: com.raytheon.uf.edex.plugin.ldadmesonet
-Bundle-Version: 1.18.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Require-Bundle: com.raytheon.uf.common.dataplugin.ldad,
- com.raytheon.uf.common.dataplugin.ldadmesonet,
- com.raytheon.edex.common,
- com.raytheon.uf.edex.pointdata
-Import-Package: com.raytheon.uf.common.status
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/build.properties b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/build.properties
deleted file mode 100644
index 20a5272307..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/build.properties
+++ /dev/null
@@ -1,6 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- utility/,\
- .,\
- res/
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/com.raytheon.uf.edex.plugin.ldadmesonet.ecl b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/com.raytheon.uf.edex.plugin.ldadmesonet.ecl
deleted file mode 100644
index e69de29bb2..0000000000
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonet.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonet.xml
deleted file mode 100644
index 0b7cba9011..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonet.xml
+++ /dev/null
@@ -1,91 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonetdb.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonetdb.xml
deleted file mode 100644
index 3c9a8bcf06..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/pointdata/ldadmesonetdb.xml
+++ /dev/null
@@ -1,30 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-common.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-common.xml
deleted file mode 100644
index c16506082e..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-common.xml
+++ /dev/null
@@ -1,21 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-ingest.xml
deleted file mode 100644
index 5e7c8a20f0..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-ingest.xml
+++ /dev/null
@@ -1,45 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- java.lang.Throwable
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/LdadmesonetPointDataTransform.java b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/LdadmesonetPointDataTransform.java
deleted file mode 100644
index 1410fbd131..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/LdadmesonetPointDataTransform.java
+++ /dev/null
@@ -1,557 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-package com.raytheon.uf.edex.plugin.ldadmesonet;
-
-import java.io.File;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.ldadmesonet.MesonetLdadRecord;
-import com.raytheon.uf.common.pointdata.PointDataContainer;
-import com.raytheon.uf.common.pointdata.PointDataDescription;
-import com.raytheon.uf.common.pointdata.PointDataView;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.edex.plugin.ldadmesonet.dao.LdadMesonetDao;
-
-/**
- * Transform LDAD MESONET records into Point Data Model.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------ ---------- ----------- --------------------------
- * Oct 09, 2009 DR2814 vkorolev Initial creation
- * Aug 30, 2013 2298 rjpeter Make getPluginName abstract
- * Jul 23, 2014 3410 bclement location changed to floats
- * Aug 15, 2014 3530 bclement moved from common to edex
- *
- *
- *
- * @author vkorolev
- * @version 1
- */
-
-public class LdadmesonetPointDataTransform {
-
- private LdadMesonetDao dao;
-
- private PointDataDescription description;
-
- // ------------------Common params (From OBS
- // plugin)----------------------------
- private static final String PRESS_CHANGE3_HOUR = "pressChange3Hour";
-
- private static final String PRESS_CHANGE_CHAR = "pressChangeChar";
-
- private static final String ALTIMETER = "altimeter";
-
- private static final String WIND_GUST = "windGust";
-
- private static final String WIND_SPEED = "windSpeed";
-
- private static final String DEWPOINT = "dewpoint";
-
- private static final String TEMPERATURE = "temperature";
-
- private static final String PRES_WEATHER = "presWeather";
-
- private static final String VISIBILITY = "visibility";
-
- private static final String LONGITUDE = "longitude";
-
- private static final String LATITUDE = "latitude";
-
- private static final String ELEVATION = "elevation";
-
- private static final String STATION_NAME = "stationName";
-
- private static final String DATAURI = "dataURI";
-
- // ------------------From LDAD mesonet netCDF------------------------
- private static final String STORAGE_TYPE = "storageType";
-
- private static final String STATION_ID = "stationId";
-
- private static final String DATA_PROVIDER = "dataProvider";
-
- private static final String HOME_WFO = "homeWFO";
-
- private static final String OBSERVATION_TIME = "observationTime";
-
- private static final String PROVIDER_ID = "providerId";
-
- private static final String HANDBOOK5_ID = "handbook5Id";
-
- private static final String STATION_TYPE = "stationType";
-
- private static final String REPORT_TIME = "reportTime";
-
- private static final String RECEIVED_TIME = "receivedTime";
-
- private static final String NUMERICAL_WMO_ID = "numericWMOid";
-
- private static final String DATA_PLATFORM_TYPE = "dataPlatformType";
-
- private static final String PLATFORM_TRUE_DIRECTION = "platformTrueDirection";
-
- private static final String PLARFORM_TRUE_SPEED = "platformTrueSpeed";
-
- private static final String TEMP_CHANGE_TIME = "tempChangeTime";
-
- private static final String WET_BULB_TEMPERATURE = "wetBulbTemperature";
-
- private static final String RH_CHANGE_TIME = "rhChangeTime";
-
- private static final String STATION_PRESSURE = "stationPressure";
-
- private static final String STATION_PRESS_CHANGE_TIME = "stationPressChangeTime";
-
- private static final String WIND_DIR_CHANGE_TIME = "windDirChangeTime";
-
- private static final String WIND_SPEED_CHANGE_TIME = "windSpeedChangeTime";
-
- private static final String WIND_GUST_CHANGE_TIME = "windGustChangeTime";
-
- private static final String WIND_DIR_MIN = "windDirMin";
-
- private static final String WIND_DIR_MAX = "windDirMax";
-
- private static final String VISIBILITY_STATUS = "visibilityStatus";
-
- private static final String TOTAL_CLOUD_COVER = "totalCloudCover";
-
- private static final String CLOUD_BASE_HEIGHT = "cloudBaseHeight";
-
- private static final String LOW_LEVEL_CLOUD_TYPE = "lowLevelCloudType";
-
- private static final String MID_LEVEL_CLOUD_TYPE = "midLevelCloudType";
-
- private static final String HIGH_LEVEL_CLOUD_TYPE = "highLevelCloudType";
-
- private static final String MAX_TEMP_RECORD_PERIOD = "maxTempRecordPeriod";
-
- private static final String MAXIMUM_TEMPERATURE = "maximumTemperature";
-
- private static final String MIN_TEMP_RECORD_PERIOD = "minTempRecordPeriod";
-
- private static final String MINIMUM_TEMPERATURE = "minimumTemperature";
-
- private static final String PRECIP_ACCUM = "precipAccum";
-
- private static final String PRECIP_TYPE = "precipType";
-
- private static final String PRECIP_INTENSITY = "precipIntensity";
-
- private static final String TIME_SINCE_LAST_PCP = "timeSinceLastPcp";
-
- private static final String SOLAR_RADIATION = "solarRadiation";
-
- private static final String SOLAR_RAD_CHANGE_TIME = "solarRadChangeTime";
-
- private static final String SEA_SURFACE_TEMP = "seaSurfaceTemp";
-
- private static final String WAVE_PERIOD = "wavePeriod";
-
- private static final String WAVE_HEIGHT = "waveHeight";
-
- private static final String RAW_MESONET = "rawMessage";
-
- private static final String REL_HUMIDITY = "relHumidity";
-
- private static final String WIND_DIR = "windDir";
-
- private static final String PRESSURE = "pressure";
-
- private static final String SEA_LEVEL_PRESSURE = "seaLevelPressure";
-
- private static final String PRECIP_RATE = "precipRate";
-
- private static final String FUEL_TEMPERATURE = "fuelTemperature";
-
- private static final String FUEL_MOISTURE = "fuelMoisture";
-
- private static final String SOIL_TEMPERATURE = "soilTemperature";
-
- private static final String SOIL_MOISTURE = "soilMoisture";
-
- /**
- * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! It is important to
- * keep this up to date or risk breaking backwards compatibility
- *
- */
- private static final String[] ALL_PARAMS = { PRESS_CHANGE3_HOUR,
- PRESS_CHANGE_CHAR, ALTIMETER, WIND_GUST, WIND_SPEED, DEWPOINT,
- TEMPERATURE, PRES_WEATHER, VISIBILITY, LONGITUDE, LATITUDE,
- SEA_LEVEL_PRESSURE, STATION_NAME, DATAURI, STORAGE_TYPE, ELEVATION,
- STATION_ID, DATA_PROVIDER, HOME_WFO, OBSERVATION_TIME, PROVIDER_ID,
- HANDBOOK5_ID, STATION_TYPE, REPORT_TIME, RECEIVED_TIME,
- NUMERICAL_WMO_ID, DATA_PLATFORM_TYPE, PLATFORM_TRUE_DIRECTION,
- PLARFORM_TRUE_SPEED, TEMP_CHANGE_TIME, WET_BULB_TEMPERATURE,
- RH_CHANGE_TIME, STATION_PRESSURE, STATION_PRESS_CHANGE_TIME,
- WIND_DIR_CHANGE_TIME, WIND_SPEED_CHANGE_TIME,
- WIND_GUST_CHANGE_TIME, WIND_DIR_MIN, WIND_DIR_MAX,
- VISIBILITY_STATUS, TOTAL_CLOUD_COVER, CLOUD_BASE_HEIGHT,
- LOW_LEVEL_CLOUD_TYPE, MID_LEVEL_CLOUD_TYPE, HIGH_LEVEL_CLOUD_TYPE,
- MAX_TEMP_RECORD_PERIOD, MAXIMUM_TEMPERATURE,
- MIN_TEMP_RECORD_PERIOD, MINIMUM_TEMPERATURE, PRECIP_ACCUM,
- PRECIP_TYPE, PRECIP_INTENSITY, TIME_SINCE_LAST_PCP,
- SOLAR_RADIATION, SOLAR_RAD_CHANGE_TIME, SEA_SURFACE_TEMP,
- WAVE_PERIOD, WAVE_HEIGHT, RAW_MESONET, REL_HUMIDITY, WIND_DIR,
- PRESSURE, SEA_LEVEL_PRESSURE, PRECIP_RATE, FUEL_TEMPERATURE,
- FUEL_MOISTURE, SOIL_TEMPERATURE, SOIL_MOISTURE };
-
- public static final String ALL_PARAMS_LIST;
- static {
- StringBuffer sb = new StringBuffer();
- boolean first = true;
- for (String s : ALL_PARAMS) {
- if (!first) {
- sb.append(", ");
- } else {
- first = false;
- }
- sb.append(s);
- }
- ALL_PARAMS_LIST = sb.toString();
- }
-
- // public LdadmesonetPointDataTransform() throws JAXBException,
- // PluginException {
- // this.description = getDescription("ldadmesonet");
- // logger.info("=============PointDataDescription loaded==============");
- // this.dao = new LdadMesonetDao("ldadmesonet");
- // }
-
- public LdadmesonetPointDataTransform() {
- try {
- this.dao = new LdadMesonetDao("ldadmesonet");
- this.description = dao.getPointDataDescription(null);
- } catch (Exception e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
-
- public PluginDataObject[] toPointData(PluginDataObject[] pdo) {
-
- if (pdo.length > 0) {
- Map pointMap = new HashMap();
-
- for (PluginDataObject p : pdo) {
- if (!(p instanceof MesonetLdadRecord)) {
- continue;
- }
-
- File f = this.dao.getFullFilePath(p);
-
- PointDataContainer pdc = pointMap.get(f);
- if (pdc == null) {
- pdc = PointDataContainer.build(this.description);
- pointMap.put(f, pdc);
- }
-
- MesonetLdadRecord mesor = (MesonetLdadRecord) p;
- PointDataView pdv = buildView(pdc, mesor);
- mesor.setPointDataView(pdv);
- }
- }
- return pdo;
- }
-
- private PointDataView buildView(PointDataContainer container,
- MesonetLdadRecord record) {
- PointDataView pdv = container.append();
-
- if (record.getRawMessage() != null) {
- pdv.setString(RAW_MESONET, record.getRawMessage());
- }
- if (record.getSeaLevelPressure() != null) {
- pdv.setFloat(SEA_LEVEL_PRESSURE, record.getSeaLevelPressure());
- }
-
- if (record.getObservationTime() != null) {
- pdv.setLong(OBSERVATION_TIME, record.getDataTime().getRefTime()
- .getTime());
- }
- if (record.getVisibility() != null) {
- pdv.setFloat(VISIBILITY, record.getVisibility());
- }
- if (record.getTemperature() != null) {
- pdv.setFloat(TEMPERATURE, record.getTemperature());
- }
- if (record.getDewpoint() != null) {
- pdv.setFloat(DEWPOINT, record.getDewpoint());
- }
- if (record.getWindSpeed() != null) {
- pdv.setFloat(WIND_SPEED, record.getWindSpeed());
- }
- if (record.getWindGust() != null) {
- pdv.setFloat(WIND_GUST, record.getWindGust());
- }
- if (record.getAltimeter() != null) {
- pdv.setFloat(ALTIMETER, record.getAltimeter());
- }
- if (record.getPressChangeChar() != null) {
- pdv.setInt(PRESS_CHANGE_CHAR, record.getPressChangeChar()
- .intValue());
- }
- if (record.getPressChange3Hour() != null) {
- pdv.setFloat(PRESS_CHANGE3_HOUR, record.getPressChange3Hour());
- }
-
- // --------------------------------------LDAD mesonet
- // specific------------------------
-
- if (record.getReportTime() != null) {
- pdv.setLong(REPORT_TIME, record.getReportTime());
- }
- if (record.getReceivedTime() != null) {
- pdv.setLong(RECEIVED_TIME, record.getReceivedTime().longValue());
- }
- if (record.getNumericWMOid() != null) {
- pdv.setLong(NUMERICAL_WMO_ID, record.getNumericWMOid());
- }
- if (record.getDataPlatformType() != null) {
- pdv.setInt(DATA_PLATFORM_TYPE, record.getDataPlatformType()
- .intValue());
- }
- if (record.getPlatformTrueDirection() != null) {
- pdv.setFloat(PLATFORM_TRUE_DIRECTION,
- record.getPlatformTrueDirection());
- }
- if (record.getPlatformTrueSpeed() != null) {
- pdv.setFloat(PLARFORM_TRUE_SPEED, record.getPlatformTrueSpeed());
- }
- if (record.getTempChangeTime() != null) {
- pdv.setLong(TEMP_CHANGE_TIME, record.getTempChangeTime()
- .longValue());
- }
- if (record.getWetBulbTemperature() != null) {
- pdv.setFloat(WET_BULB_TEMPERATURE, record.getWetBulbTemperature());
- }
- if (record.getRhChangeTime() != null) {
- pdv.setLong(RH_CHANGE_TIME, record.getRhChangeTime().longValue());
- }
- if (record.getStationPressure() != null) {
- pdv.setFloat(STATION_PRESSURE, record.getStationPressure());
- }
- if (record.getStationPressChangeTime() != null) {
- pdv.setLong(STATION_PRESS_CHANGE_TIME, record
- .getStationPressChangeTime().longValue());
- }
- if (record.getWindDirChangeTime() != null) {
- pdv.setLong(WIND_DIR_CHANGE_TIME, record.getWindDirChangeTime()
- .longValue());
- }
- if (record.getWindSpeedChangeTime() != null) {
- pdv.setLong(WIND_SPEED_CHANGE_TIME, record.getWindSpeedChangeTime()
- .longValue());
- }
- if (record.getWindGustChangeTime() != null) {
- pdv.setLong(WIND_GUST_CHANGE_TIME, record.getWindGustChangeTime()
- .longValue());
- }
- if (record.getWindDirMin() != null) {
- pdv.setFloat(WIND_DIR_MIN, record.getWindDirMin());
- }
- if (record.getWindDirMax() != null) {
- pdv.setFloat(WIND_DIR_MAX, record.getWindDirMax());
- }
- if (record.getVisibilityStatus() != null) {
- pdv.setString(VISIBILITY_STATUS, record.getVisibilityStatus());
- }
- if (record.getTotalCloudCover() != null) {
- pdv.setFloat(TOTAL_CLOUD_COVER, record.getTotalCloudCover());
- }
- if (record.getCloudBaseHeight() != null) {
- pdv.setInt(CLOUD_BASE_HEIGHT, record.getCloudBaseHeight()
- .intValue());
- }
- if (record.getLowLevelCloudType() != null) {
- pdv.setInt(LOW_LEVEL_CLOUD_TYPE, record.getLowLevelCloudType()
- .intValue());
- }
- if (record.getMidLevelCloudType() != null) {
- pdv.setInt(MID_LEVEL_CLOUD_TYPE, record.getMidLevelCloudType()
- .intValue());
- }
- if (record.getHighLevelCloudType() != null) {
- pdv.setInt(HIGH_LEVEL_CLOUD_TYPE, record.getHighLevelCloudType()
- .intValue());
- }
- if (record.getMinTempRecordPeriod() != null) {
- pdv.setInt(MAX_TEMP_RECORD_PERIOD, record.getMinTempRecordPeriod()
- .intValue());
- }
- if (record.getMaximumTemperature() != null) {
- pdv.setFloat(MAXIMUM_TEMPERATURE, record.getMaximumTemperature());
- }
- if (record.getMinTempRecordPeriod() != null) {
- pdv.setInt(MIN_TEMP_RECORD_PERIOD, record.getMinTempRecordPeriod()
- .intValue());
- }
- if (record.getMinimumTemperature() != null) {
- pdv.setFloat(MINIMUM_TEMPERATURE, record.getMinimumTemperature());
- }
- if (record.getPrecipAccum() != null) {
- pdv.setFloat(PRECIP_ACCUM, record.getPrecipAccum());
- }
- if (record.getPrecipType() != null) {
- pdv.setInt(PRECIP_TYPE, record.getPrecipType().intValue());
- }
- if (record.getPrecipIntensity() != null) {
- pdv.setInt(PRECIP_INTENSITY, record.getPrecipIntensity().intValue());
- }
- if (record.getTimeSinceLastPcp() != null) {
- pdv.setLong(TIME_SINCE_LAST_PCP, record.getTimeSinceLastPcp()
- .longValue());
- }
- if (record.getSolarRadiation() != null) {
- pdv.setFloat(SOLAR_RADIATION, record.getSolarRadiation());
- }
- if (record.getSolarRadChangeTime() != null) {
- pdv.setLong(SOLAR_RAD_CHANGE_TIME, record.getSolarRadChangeTime()
- .longValue());
- }
- if (record.getSeaSurfaceTemp() != null) {
- pdv.setFloat(SEA_SURFACE_TEMP, record.getSeaSurfaceTemp());
- }
- if (record.getWavePeriod() != null) {
- pdv.setFloat(WAVE_PERIOD, record.getWavePeriod());
- }
- if (record.getWaveHeight() != null) {
- pdv.setFloat(WAVE_HEIGHT, record.getWaveHeight());
- }
- if (record.getRelHumidity() != null) {
- pdv.setFloat(REL_HUMIDITY, record.getRelHumidity());
- }
- if (record.getWindDir() != null) {
- pdv.setFloat(WIND_DIR, record.getWindDir());
- }
- if (record.getPressure() != null) {
- pdv.setFloat(PRESSURE, record.getPressure());
- }
- if (record.getSeaLevelPressure() != null) {
- pdv.setFloat(SEA_LEVEL_PRESSURE, record.getSeaLevelPressure());
- }
- if (record.getPrecipRate() != null) {
- pdv.setFloat(PRECIP_RATE, record.getPrecipRate());
- }
- if (record.getFuelTemperature() != null) {
- pdv.setFloat(FUEL_TEMPERATURE, record.getFuelTemperature());
- }
- if (record.getFuelMoisture() != null) {
- pdv.setFloat(FUEL_MOISTURE, record.getFuelMoisture());
- }
- if (record.getSoilTemperature() != null) {
- pdv.setFloat(SOIL_TEMPERATURE, record.getSoilTemperature());
- }
- if (record.getSoilMoisture() != null) {
- pdv.setFloat(SOIL_MOISTURE, record.getSoilMoisture());
- }
- return pdv;
- }
-
- public static MesonetLdadRecord toMesonetLdadRecord(PointDataView pdv) {
- MesonetLdadRecord mr = new MesonetLdadRecord();
- mr.setAltimeter(pdv.getNumber(ALTIMETER).floatValue());
- mr.setDewpoint(pdv.getNumber(DEWPOINT).floatValue());
- SurfaceObsLocation loc = new SurfaceObsLocation(
- pdv.getString(STATION_ID));
- float lat = pdv.getNumber(LATITUDE).floatValue();
- float lon = pdv.getNumber(LONGITUDE).floatValue();
- loc.assignLocation(lat, lon);
- loc.setElevation(pdv.getNumber(ELEVATION).intValue());
- mr.setLocation(loc);
- mr.setReportType(pdv.getString(STORAGE_TYPE));
- mr.setProviderId(pdv.getString(PROVIDER_ID));
- mr.setPressChange3Hour(pdv.getNumber(PRESS_CHANGE3_HOUR).floatValue());
- mr.setPressChangeChar((short) pdv.getInt(PRESS_CHANGE_CHAR));
- mr.setSeaLevelPressure(pdv.getNumber(SEA_LEVEL_PRESSURE).floatValue());
- mr.setTemperature(pdv.getNumber(TEMPERATURE).floatValue());
- mr.setVisibility(pdv.getNumber(VISIBILITY).floatValue());
- mr.setWindDir(pdv.getFloat(WIND_DIR));
- mr.setWindGust(pdv.getFloat(WIND_GUST));
- mr.setWindSpeed(pdv.getFloat(WIND_SPEED));
- mr.setDataURI(pdv.getString(DATAURI));
- mr.setReceivedTime(pdv.getNumber(RECEIVED_TIME).doubleValue());
- // ----------------------------------------------------------------------------------
- mr.setTempChangeTime(pdv.getNumber(TEMP_CHANGE_TIME).doubleValue());
- mr.setWetBulbTemperature(pdv.getFloat(WET_BULB_TEMPERATURE));
- mr.setRhChangeTime((Double) pdv.getNumber(RH_CHANGE_TIME));
- mr.setStationPressure(pdv.getFloat(STATION_PRESSURE));
- mr.setStationPressChangeTime((Double) pdv
- .getNumber(STATION_PRESS_CHANGE_TIME));
- mr.setWindDirChangeTime((Double) pdv.getNumber(WIND_DIR_CHANGE_TIME));
- mr.setWindSpeedChangeTime((Double) pdv
- .getNumber(WIND_SPEED_CHANGE_TIME));
- mr.setWindGustChangeTime((Double) pdv.getNumber(WIND_GUST_CHANGE_TIME));
- mr.setWindDirMin(pdv.getFloat(WIND_DIR_MIN));
- mr.setWindDirMax(pdv.getFloat(WIND_DIR_MAX));
- mr.setVisibilityStatus(pdv.getString(VISIBILITY_STATUS));
- mr.setTotalCloudCover(pdv.getFloat(TOTAL_CLOUD_COVER));
- mr.setCloudBaseHeight((Short) pdv.getNumber(CLOUD_BASE_HEIGHT));
- mr.setLowLevelCloudType((Short) pdv.getNumber(LOW_LEVEL_CLOUD_TYPE));
- mr.setMidLevelCloudType((Short) pdv.getNumber(MID_LEVEL_CLOUD_TYPE));
- mr.setHighLevelCloudType((Short) pdv.getNumber(HIGH_LEVEL_CLOUD_TYPE));
- mr.setMaxTempRecordPeriod((Short) pdv.getNumber(MAX_TEMP_RECORD_PERIOD));
- mr.setMaximumTemperature(pdv.getFloat(MAXIMUM_TEMPERATURE));
- mr.setMinTempRecordPeriod((Short) pdv.getNumber(MIN_TEMP_RECORD_PERIOD));
- mr.setMaximumTemperature(pdv.getFloat(MINIMUM_TEMPERATURE));
- mr.setPrecipAccum(pdv.getFloat(PRECIP_ACCUM));
- mr.setPrecipType((Short) pdv.getNumber(PRECIP_TYPE));
- mr.setPrecipIntensity((Short) pdv.getNumber(PRECIP_INTENSITY));
- mr.setTimeSinceLastPcp((Double) pdv.getNumber(TIME_SINCE_LAST_PCP));
- mr.setSolarRadiation(pdv.getFloat(SOLAR_RADIATION));
- mr.setSolarRadChangeTime((Double) pdv.getNumber(SOLAR_RAD_CHANGE_TIME));
- mr.setSeaSurfaceTemp(pdv.getFloat(SEA_SURFACE_TEMP));
- mr.setWavePeriod(pdv.getFloat(WAVE_PERIOD));
- mr.setWaveHeight(pdv.getFloat(WAVE_HEIGHT));
- mr.setRawMessage(pdv.getString(RAW_MESONET));
- mr.setRelHumidity(pdv.getFloat(REL_HUMIDITY));
- mr.setWindDir(pdv.getFloat(WIND_DIR));
- mr.setPressure(pdv.getFloat(PRESSURE));
- mr.setSeaLevelPressure(pdv.getFloat(SEA_LEVEL_PRESSURE));
- mr.setPrecipRate(pdv.getFloat(PRECIP_RATE));
- mr.setFuelTemperature(pdv.getFloat(FUEL_TEMPERATURE));
- mr.setFuelMoisture(pdv.getFloat(FUEL_MOISTURE));
- mr.setSoilTemperature(pdv.getFloat(SOIL_TEMPERATURE));
- mr.setSoilMoisture(pdv.getFloat(SOIL_MOISTURE));
- return mr;
- }
-
- public static MesonetLdadRecord[] toMesonetLdadRecords(
- PointDataContainer container) {
- List records = new ArrayList();
- container.setCurrentSz(container.getAllocatedSz());
- for (int i = 0; i < container.getCurrentSz(); i++) {
- PointDataView pdv = container.readRandom(i);
- records.add(toMesonetLdadRecord(pdv));
- }
- return records.toArray(new MesonetLdadRecord[records.size()]);
-
- }
-
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/dao/LdadMesonetDao.java b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/dao/LdadMesonetDao.java
deleted file mode 100644
index b7fa03e29b..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/src/com/raytheon/uf/edex/plugin/ldadmesonet/dao/LdadMesonetDao.java
+++ /dev/null
@@ -1,163 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-package com.raytheon.uf.edex.plugin.ldadmesonet.dao;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import com.raytheon.uf.common.dataplugin.PluginException;
-import com.raytheon.uf.common.dataplugin.ldadmesonet.MesonetLdadRecord;
-import com.raytheon.uf.common.dataquery.db.QueryParam;
-import com.raytheon.uf.common.pointdata.spatial.ObStation;
-import com.raytheon.uf.edex.database.DataAccessLayerException;
-import com.raytheon.uf.edex.database.query.DatabaseQuery;
-import com.raytheon.uf.edex.pointdata.PointDataPluginDao;
-import com.raytheon.uf.edex.pointdata.spatial.ObStationDao;
-
-/**
- * Data access object for accessing LDAD MESONET records in the database.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------ ---------- ----------- --------------------------
- * 9/04/09 vkorolev Initial creation
- * 10/09/09 DR2814 vkorolev Refactor to Point Data Model
- * Feb 27, 2013 1638 mschenke Moved ObStationDao to edex pointdata plugin
- * Aug 15, 2014 3530 bclement moved from common to edex
- * Feb 16, 2022 8608 mapeters Remove populateDataStore override that matched super
- *
- *
- *
- * @author vkorolev
- */
-public class LdadMesonetDao extends PointDataPluginDao {
-
- /** The station dao */
- private ObStationDao obDao = new ObStationDao();
-
- public LdadMesonetDao(String pluginName) throws PluginException {
- super(pluginName);
- }
-
- public LdadMesonetDao() throws PluginException {
- this("ldadmesonet");
- }
-
- public List queryBySpatialBox(double upperLeftLat, double upperLeftLon,
- double lowerRightLat, double lowerRightLon)
- throws DataAccessLayerException {
-
- List stationList = obDao.queryBySpatialBox(upperLeftLat,
- upperLeftLon, lowerRightLat, lowerRightLon);
-
- List stationNames = new ArrayList<>();
- for (ObStation station : stationList) {
- stationNames.add(station.getIdentifier());
- }
- stationList.clear();
-
- DatabaseQuery query = new DatabaseQuery(MesonetLdadRecord.class);
- query.addQueryParam("location.stationId", stationNames,
- QueryParam.QueryOperand.IN);
- return queryByCriteria(query);
- }
-
- public List queryByState(String state, Integer count)
- throws DataAccessLayerException {
-
- List results = obDao.queryByState(state);
-
- List icaos = new ArrayList<>();
- for (ObStation station : results) {
- icaos.add(station.getIdentifier());
- }
-
- DatabaseQuery query = new DatabaseQuery(MesonetLdadRecord.class, count);
- query.addQueryParam("location.stationId", icaos,
- QueryParam.QueryOperand.IN);
- return queryByCriteria(query);
- }
-
- /**
- * Retrieves an ldadMesonet report using the datauri .
- *
- * @param dataURI
- * The dataURI to match against.
- * @return The report record if it exists.
- */
- public MesonetLdadRecord queryByDataURI(String dataURI) {
- MesonetLdadRecord report = null;
- List obs = null;
- try {
- obs = queryBySingleCriteria("dataURI", dataURI);
- } catch (DataAccessLayerException e) {
- logger.error("Error querying LDAD Mesonet data by URI: " + dataURI,
- e);
- }
- if (obs != null && !obs.isEmpty()) {
- report = (MesonetLdadRecord) obs.get(0);
- }
- return report;
- }
-
- /**
- * Queries for to determine if a given data uri exists on the redbook table.
- *
- * @param dataUri
- * The DataURI to find.
- * @return An array of objects. If not null, there should only be a single
- * element.
- */
- public Object[] queryDataUriColumn(final String dataUri) {
-
- String sql = "select datauri from awips.ldadmesonet where datauri='"
- + dataUri + "';";
-
- Object[] results = executeSQLQuery(sql);
-
- return results;
- }
-
- public ObStationDao getObDao() {
- return obDao;
- }
-
- public void setObDao(ObStationDao obDao) {
- this.obDao = obDao;
- }
-
- @Override
- public String[] getKeysRequiredForFileName() {
- return new String[] { "dataTime.refTime" };
- }
-
- @Override
- public String getPointDataFileName(MesonetLdadRecord p) {
- return "ldadmesonet.h5";
- }
-
- @Override
- public MesonetLdadRecord newObject() {
- return new MesonetLdadRecord();
- }
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/distribution/ldadmesonet.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/distribution/ldadmesonet.xml
deleted file mode 100644
index ad3b39d7a3..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/distribution/ldadmesonet.xml
+++ /dev/null
@@ -1,29 +0,0 @@
-
-
-
-
-
- LDAD\.mesonet\.*
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/purge/ldadmesonetPurgeRules.xml b/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/purge/ldadmesonetPurgeRules.xml
deleted file mode 100644
index f305712e99..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/utility/common_static/base/purge/ldadmesonetPurgeRules.xml
+++ /dev/null
@@ -1,36 +0,0 @@
-
-
-
-
-
-
- 24
- =00-01:00:00
- 00-01:00:00
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.classpath b/edexOsgi/com.raytheon.uf.edex.plugin.qc/.classpath
deleted file mode 100644
index 1fa3e6803d..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.classpath
+++ /dev/null
@@ -1,7 +0,0 @@
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.project b/edexOsgi/com.raytheon.uf.edex.plugin.qc/.project
deleted file mode 100644
index 37b171dac2..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.project
+++ /dev/null
@@ -1,34 +0,0 @@
-
-
- com.raytheon.uf.edex.plugin.qc
-
-
-
-
-
- org.python.pydev.PyDevBuilder
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.pde.ManifestBuilder
-
-
-
-
- org.eclipse.pde.SchemaBuilder
-
-
-
-
-
- org.eclipse.pde.PluginNature
- org.eclipse.jdt.core.javanature
- org.python.pydev.pythonNature
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.pydevproject b/edexOsgi/com.raytheon.uf.edex.plugin.qc/.pydevproject
deleted file mode 100644
index faf12629d9..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/.pydevproject
+++ /dev/null
@@ -1,7 +0,0 @@
-
-
-
-
-python 2.5
-Default
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/META-INF/MANIFEST.MF b/edexOsgi/com.raytheon.uf.edex.plugin.qc/META-INF/MANIFEST.MF
deleted file mode 100644
index 76044450d6..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/META-INF/MANIFEST.MF
+++ /dev/null
@@ -1,13 +0,0 @@
-Manifest-Version: 1.0
-Bundle-ManifestVersion: 2
-Bundle-Name: Qc Plug-in
-Bundle-SymbolicName: com.raytheon.uf.edex.plugin.qc
-Bundle-Version: 1.18.0.qualifier
-Bundle-Vendor: RAYTHEON
-Bundle-RequiredExecutionEnvironment: JavaSE-1.8
-Require-Bundle: com.raytheon.edex.common,
- com.raytheon.uf.edex.pointdata,
- com.raytheon.uf.common.dataplugin.qc,
- com.raytheon.uf.common.localization,
- ucar.nc2
-Import-Package: com.raytheon.uf.common.status
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/build.properties b/edexOsgi/com.raytheon.uf.edex.plugin.qc/build.properties
deleted file mode 100644
index 9d91e04a59..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/build.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-source.. = src/
-output.. = bin/
-bin.includes = META-INF/,\
- utility/,\
- .,\
- res/,\
- resources/
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/com.raytheon.uf.edex.plugin.qc.ecl b/edexOsgi/com.raytheon.uf.edex.plugin.qc/com.raytheon.uf.edex.plugin.qc.ecl
deleted file mode 100644
index e69de29bb2..0000000000
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/ldadmesonet.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/ldadmesonet.xml
deleted file mode 100644
index 98dabd8ea9..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/ldadmesonet.xml
+++ /dev/null
@@ -1,58 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/msas.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/msas.xml
deleted file mode 100644
index 86a22c7105..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/pdd/msas.xml
+++ /dev/null
@@ -1,61 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/qcdb.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/qcdb.xml
deleted file mode 100644
index b7e7f6b5ce..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/pointdata/qcdb.xml
+++ /dev/null
@@ -1,29 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-common.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-common.xml
deleted file mode 100644
index c3c2e59634..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-common.xml
+++ /dev/null
@@ -1,19 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-ingest.xml
deleted file mode 100644
index 77f115f66f..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-ingest.xml
+++ /dev/null
@@ -1,61 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
- qc
-
-
-
-
-
-
- java.lang.Throwable
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- java.lang.Throwable
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/resources/qc.properties b/edexOsgi/com.raytheon.uf.edex.plugin.qc/resources/qc.properties
deleted file mode 100644
index 2d0bea424f..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/resources/qc.properties
+++ /dev/null
@@ -1,2 +0,0 @@
-# period to scan the QC file drop point for new QC data
-qc.cron=0+2,7,12,17,22,27,32,37,42,47,52,57+*+*+*+?
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/QCScanner.java b/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/QCScanner.java
deleted file mode 100644
index 4cde543c2d..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/QCScanner.java
+++ /dev/null
@@ -1,370 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-
-package com.raytheon.uf.edex.plugin.qc;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.regex.Pattern;
-
-import com.raytheon.uf.common.dataplugin.PluginDataObject;
-import com.raytheon.uf.common.dataplugin.qc.QCRecord;
-import com.raytheon.uf.common.pointdata.PointDataContainer;
-import com.raytheon.uf.common.pointdata.PointDataDescription;
-import com.raytheon.uf.common.pointdata.PointDataView;
-import com.raytheon.uf.common.pointdata.spatial.SurfaceObsLocation;
-import com.raytheon.uf.common.status.IUFStatusHandler;
-import com.raytheon.uf.common.status.UFStatus;
-import com.raytheon.uf.common.time.DataTime;
-import com.raytheon.uf.edex.database.plugin.PluginFactory;
-import com.raytheon.uf.edex.plugin.qc.dao.QCDao;
-import com.raytheon.uf.edex.plugin.qc.internal.QCPaths;
-
-import ucar.ma2.Array;
-import ucar.ma2.ArrayChar;
-import ucar.ma2.DataType;
-import ucar.ma2.Section;
-import ucar.nc2.Attribute;
-import ucar.nc2.NetcdfFile;
-import ucar.nc2.Variable;
-
-/**
- * Scans NetCDF files generated by A1 legacy applications and generates QCRecord
- * instances that refer to their records. The scan should only occur on one JVM
- * in a cluster while the decode can occur on multiple JVMs in a cluster.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------ ---------- ----------- --------------------------
- * Dec 03, 2010 4775 D. Friedman Initial version
- * Mar 07, 2013 15842 D. Friedman Use Java NetCDF library instead of
- * pupynere
- * May 16, 2013 1869 bsteffen Remove DataURI column from qc.
- * Aug 30, 2013 2298 rjpeter Make getPluginName abstract
- * Feb 20, 2014 DR 17098 D. Friedman Filter out invalid lat/lon values.
- * Jul 23, 2014 3410 bclement location changed to floats
- * Jan 03, 2018 6861 njensen Split on files, decode and store results
- * as PointDataView on PluginDataObject[]
- *
- *
- *
- * @author dfriedma
- */
-public class QCScanner {
-
- private static final IUFStatusHandler statusHandler = UFStatus
- .getHandler(QCScanner.class);
-
- private static final Pattern FILE_PATTERN = Pattern.compile("^\\d+_\\d+$");
-
- private Integer maxRecordsInChunk;
-
- /**
- * Map of qcType to filename to last mod time. Used to ensure we don't scan
- * a file again if it hasn't changed.
- */
- private Map> fileLastScannedMap = new HashMap<>();
-
- /**
- * @return the maxRecordsInChunk
- */
- public Integer getMaxRecordsInChunk() {
- return maxRecordsInChunk;
- }
-
- /**
- * @param maxRecordsInChunk
- * the maxRecordsInChunk to set
- */
- public void setMaxRecordsInChunk(Integer maxRecordsInChunk) {
- this.maxRecordsInChunk = maxRecordsInChunk;
- }
-
- /**
- * Information necessary to start a decode. Serialized after the split to
- * take advantage of clustering the decodes.
- */
- public static class QCFile implements Serializable {
-
- private static final long serialVersionUID = 1L;
-
- protected String qcType;
-
- protected File file;
-
- protected QCFile(String qcType, File file) {
- this.qcType = qcType;
- this.file = file;
- }
- }
-
- public class QCDirectoryScanner {
- private final String qcType;
-
- private final File directory;
-
- public QCDirectoryScanner(String qcType, File directory) {
- this.qcType = qcType;
- this.directory = directory;
- }
-
- /**
- * Scan all files in the directory that match the pattern and have been
- * modified since we last scanned them. If we did not previously scan
- * them, then scan those too.
- *
- * @return the list of QCFiles that match the pattern and have been
- * modified since we last scanned them
- */
- public List getFiles() {
- List results = new ArrayList<>();
- Map updatedScanMap = new HashMap<>();
- Map innerMap = fileLastScannedMap.get(qcType);
- if (innerMap == null) {
- innerMap = new HashMap<>();
- }
-
- for (String fn : directory.list()) {
- if (FILE_PATTERN.matcher(fn).matches()) {
- try {
- File f = new File(directory, fn);
- String path = f.getPath();
- Long lastScanned = innerMap.get(path);
- if (lastScanned == null
- || f.lastModified() > lastScanned) {
- QCFile qcf = new QCFile(qcType, f);
- results.add(qcf);
- lastScanned = f.lastModified();
- }
- updatedScanMap.put(path, lastScanned);
- } catch (Exception e) {
- statusHandler
- .error(String.format("error reading %s/%s: %s",
- directory, fn, e.getMessage()), e);
- }
- }
- }
-
- fileLastScannedMap.put(qcType, updatedScanMap);
- return results;
- }
- }
-
- /**
- * Gets an iterator of QC files to process/decode.
- *
- * @return an iterator of QC files
- * @throws FileNotFoundException
- */
- public Iterator split() throws FileNotFoundException {
- List files = new ArrayList<>();
- Map paths = QCPaths.getPaths();
- for (Map.Entry entry : paths.entrySet()) {
- String type = entry.getKey();
- File directory = entry.getValue();
- QCDirectoryScanner scanner = new QCDirectoryScanner(type,
- directory);
- files.addAll(scanner.getFiles());
- }
-
- return files.iterator();
- }
-
- /**
- * Scans or "decodes" the QC netcdf file into QCRecords
- *
- * @param qcFile
- * the QC file to scan for records
- * @return the PluginDataObjects that were "decoded"
- * @throws Exception
- */
- public PluginDataObject[] scanFile(QCFile qcFile) throws Exception {
- try (NetcdfFile nc = NetcdfFile.open(qcFile.file.getPath())) {
- int index = 0;
- int totalRecordCount = nc.getUnlimitedDimension().getLength();
- int batchSize = Math.min(getMaxRecordsInChunk(), totalRecordCount);
-
- String[] idVariablesNames = nc.findGlobalAttribute("idVariables")
- .getStringValue().split(",");
- String[] timeVariableNames = nc.findGlobalAttribute("timeVariables")
- .getStringValue().split(",");
- Variable[] idVariables = new Variable[idVariablesNames.length];
- for (int i = 0; i < idVariables.length; ++i) {
- idVariables[i] = nc.findVariable(idVariablesNames[i]);
- }
- Variable vObsTime = nc.findVariable(timeVariableNames[0]);
- double vObsTimeFillValue = vObsTime.findAttribute("_FillValue")
- .getNumericValue().doubleValue();
- Double vObsTimeMissingValue = null;
- Attribute a = vObsTime.findAttribute("missing_value");
- if (a != null) {
- vObsTimeMissingValue = a.getNumericValue().doubleValue();
- }
- Variable vLat = nc.findVariable("latitude");
- Variable vLon = nc.findVariable("longitude");
- Variable vElev = nc.findVariable("elevation");
-
- /*
- * There's so many variables in the file that we don't need so we
- * pick the ones we do need from the point data description.
- */
- QCDao qcDao = (QCDao) PluginFactory.getInstance()
- .getPluginDao("qc");
- Map map = new HashMap<>();
- map.put("qcType", qcFile.qcType);
- PointDataDescription pdd = qcDao.getPointDataDescription(map);
- PointDataContainer pdc = PointDataContainer.build(pdd);
- Map variableMap = new HashMap<>();
- for (String name : pdd.getParameterNames()) {
- /*
- * do not include id variables, we will read those separately
- * below because they are 2-dimensional chars (aka Strings)
- */
- boolean foundId = false;
- for (String idName : idVariablesNames) {
- if (idName.equals(name)) {
- foundId = true;
- break;
- }
- }
- if (!foundId) {
- Variable v = nc.findVariable(name);
- if (v != null) {
- variableMap.put(name, v);
- }
- }
- }
-
- Map recordMap = new HashMap<>();
- while (index < totalRecordCount) {
- batchSize = Math.min(batchSize, totalRecordCount - index);
- int[] ofs = new int[] { index };
- int[] len = new int[] { batchSize };
- Array dObsTime = vObsTime.read(ofs, len);
- Array dLat = vLat.read(ofs, len);
- Array dLon = vLon.read(ofs, len);
- Array dElev = vElev.read(ofs, len);
-
- // get IDs which will become the unique station name
- Section sec = new Section();
- sec.appendRange(index, (index + batchSize) - 1);
- sec.appendRange();
- ArrayChar[] dIDs = new ArrayChar[idVariables.length];
- for (int i = 0; i < dIDs.length; ++i) {
- dIDs[i] = (ArrayChar) idVariables[i].read(sec);
- }
-
- Map nameToArrayMap = new HashMap<>();
- for (Variable v : variableMap.values()) {
- Array arr = v.read(ofs, len);
- nameToArrayMap.put(v.getName(), arr);
- }
-
- int ri = 0;
- while (ri < batchSize) {
- PointDataView pdv = pdc.append();
- QCRecord pdo = new QCRecord();
- pdo.setOverwriteAllowed(true);
- double obsTime = dObsTime.getDouble(ri);
- float lat = dLat.getFloat(ri);
- float lon = dLon.getFloat(ri);
- if ((obsTime != vObsTimeFillValue)
- && ((vObsTimeMissingValue == null)
- || (vObsTimeMissingValue != obsTime))
- && Math.abs(lon) <= 180 && Math.abs(lat) <= 90) {
- pdo.setDataTime(new DataTime(
- new Date((long) (obsTime * 1000))));
- SurfaceObsLocation loc = new SurfaceObsLocation();
- loc.assignLocation(lat, lon);
- loc.setElevation(dElev.getInt(ri));
-
- /*
- * Set up a unique stationId while also setting the id
- * variable names with point data values
- */
- StringBuilder stationId = new StringBuilder();
- for (ArrayChar idArray : dIDs) {
- stationId.append(idArray.getString(ri));
- }
- loc.setStationId(stationId.toString());
- for (int i = 0; i < idVariablesNames.length; i++) {
- pdv.setString(idVariablesNames[i],
- dIDs[i].getString(ri));
- }
-
- pdo.setLocation(loc);
- pdo.setNcSet(qcFile.file.getName());
- pdo.setQcType(qcFile.qcType);
-
- for (String name : nameToArrayMap.keySet()) {
- Array arr = nameToArrayMap.get(name);
- DataType dtype = arr.getDataType();
- switch (dtype) {
- case CHAR:
- pdv.setString(name,
- String.valueOf(arr.getChar(ri)));
- break;
- case INT:
- case SHORT:
- pdv.setInt(name, arr.getInt(ri));
- break;
- case LONG:
- pdv.setLong(name, arr.getLong(ri));
- break;
- case FLOAT:
- case DOUBLE:
- pdv.setFloat(name, arr.getFloat(ri));
- break;
- default:
- throw new IllegalArgumentException(
- "QCScanner does not support reading values of type "
- + dtype);
- }
-
- }
- pdo.setPointDataView(pdv);
- recordMap.put(pdo.getDataURI(), pdo);
- }
- ++index;
- ++ri;
-
- }
-
- } // end of outer while
-
- Collection results = recordMap.values();
- int size = results.size();
- statusHandler.info("Decoded " + size + " QC records from "
- + qcFile.file.getPath() + ", now storing");
- return results.toArray(new PluginDataObject[size]);
- }
- }
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/dao/QCDao.java b/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/dao/QCDao.java
deleted file mode 100644
index a48d107df8..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/dao/QCDao.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-
-package com.raytheon.uf.edex.plugin.qc.dao;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import com.raytheon.uf.common.dataplugin.PluginException;
-import com.raytheon.uf.common.dataplugin.qc.QCRecord;
-import com.raytheon.uf.common.pointdata.PointDataDescription;
-import com.raytheon.uf.edex.plugin.qc.internal.QCPaths;
-import com.raytheon.uf.edex.pointdata.PointDataPluginDao;
-
-/**
- * Data access object for retrieving QC mesonet data.
- *
- *
- *
- * SOFTWARE HISTORY
- * Date Ticket# Engineer Description
- * ------------ ---------- ----------- --------------------------
- * 12/04/2009 3408 bphillip Initial creation
- * Aug 15, 2014 3530 bclement removed commons logging
- * Apr 16, 2015 4259 njensen Removed unreachable catch
- * Jan 04, 2018 6861 njensen Removed python usage, removed method overrides
- * so it mostly resembles a normal pointdata plugin
- *
- *
- *
- * @author bphillip
- */
-public class QCDao extends PointDataPluginDao {
-
- /** Map of plugin names to point data descriptions */
- private static Map pdds = new HashMap<>();
-
- static {
- pdds = QCPaths.getPointDataDescriptions();
- }
-
- /**
- * Constructs a new QC data access object
- *
- * @param pluginName
- * "qc"
- * @throws PluginException
- * If errors occur while constructing the data access object
- */
- public QCDao(String pluginName) throws PluginException {
- super(pluginName);
- }
-
- @Override
- public String[] getKeysRequiredForFileName() {
- return new String[] { "qcType", "dataTime.refTime" };
- }
-
- @Override
- public String getPointDataFileName(QCRecord p) {
- return "qc.h5";
- }
-
- @Override
- public QCRecord newObject() {
- return new QCRecord();
- }
-
- @Override
- public PointDataDescription getPointDataDescription(
- Map obj) {
- return pdds.get(obj.get("qcType").toString());
- }
-
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/internal/QCPaths.java b/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/internal/QCPaths.java
deleted file mode 100644
index 45bd9e92d8..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/src/com/raytheon/uf/edex/plugin/qc/internal/QCPaths.java
+++ /dev/null
@@ -1,123 +0,0 @@
-/**
- * This software was developed and / or modified by Raytheon Company,
- * pursuant to Contract DG133W-05-CQ-1067 with the US Government.
- *
- * U.S. EXPORT CONTROLLED TECHNICAL DATA
- * This software product contains export-restricted data whose
- * export/transfer/disclosure is restricted by U.S. law. Dissemination
- * to non-U.S. persons whether in the United States or abroad requires
- * an export license or other authorization.
- *
- * Contractor Name: Raytheon Company
- * Contractor Address: 6825 Pine Street, Suite 340
- * Mail Stop B8
- * Omaha, NE 68106
- * 402.291.0100
- *
- * See the AWIPS II Master Rights File ("Master Rights File.pdf") for
- * further licensing information.
- **/
-
-package com.raytheon.uf.edex.plugin.qc.internal;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.HashMap;
-import java.util.Map;
-
-import com.raytheon.uf.common.pointdata.PointDataDescription;
-import com.raytheon.uf.common.serialization.SerializationException;
-import com.raytheon.uf.edex.core.EDEXUtil;
-
-/**
- * This class should only be used by the QC plug-ins.
- *
- *
- *
- * SOFTWARE HISTORY
- *
- * Date Ticket# Engineer Description
- * ------------- -------- --------- --------------------------------------------
- * ??? ??? ??? Initial creation
- * Aug 15, 2014 3530 bclement moved from common to edex
- * Jul 15, 2016 5744 mapeters Use common_static instead of edex_static
- * in getPythonScriptPath()
- * Jan 05, 2018 6861 njensen Removed python support
- * Simplified getPointDataDescriptions()
- *
- *
- *
- */
-public class QCPaths {
-
- /** The directory containing the raw QC mesonet data */
- private static final String QC_RAW_DIR;
-
- static {
- QC_RAW_DIR = EDEXUtil.getEdexData() + File.separator
- + System.getProperty("HDF5_PATH");
- }
-
- public static Map getPaths() throws FileNotFoundException {
- Map paths = new HashMap<>();
- File baseDir = new File(QC_RAW_DIR);
- if (baseDir.exists()) {
- File[] files = baseDir.listFiles();
- if (files == null) {
- throw new FileNotFoundException(
- "Unable to read files in directory: " + baseDir);
- }
- for (File f : files) {
- paths.put(f.getName(), f);
- }
- } else {
- throw new FileNotFoundException(
- "Unable to open directory: " + baseDir);
- }
- return paths;
- }
-
- public static Map getPointDataDescriptions() {
- Map pdds = new HashMap<>();
- String mesonetPath = "/res/pointdata/pdd/ldadmesonet.xml";
- String msasPath = "/res/pointdata/pdd/msas.xml";
-
- try (InputStream is = QCPaths.class.getResourceAsStream(mesonetPath)) {
- PointDataDescription desc;
- try {
- desc = PointDataDescription.fromStream(is);
- pdds.put("ldadmesonet", desc);
- } catch (SerializationException e) {
- throw new RuntimeException(
- "Error reading pointdata description from "
- + mesonetPath,
- e);
- }
- } catch (IOException e) {
- // ignore
- }
-
- try (InputStream is = QCPaths.class.getResourceAsStream(msasPath)) {
- PointDataDescription desc;
- try {
- desc = PointDataDescription.fromStream(is);
- pdds.put("msas", desc);
- } catch (SerializationException e) {
- throw new RuntimeException(
- "Error reading pointdata description from " + msasPath,
- e);
- }
- } catch (IOException e) {
- // ignore
- }
-
- return pdds;
- }
-
- public static String getBaseDir() {
- return QC_RAW_DIR;
- }
-
-}
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qc/utility/common_static/base/path/qcPathKeys.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qc/utility/common_static/base/path/qcPathKeys.xml
deleted file mode 100644
index eddffb6f5c..0000000000
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qc/utility/common_static/base/path/qcPathKeys.xml
+++ /dev/null
@@ -1,32 +0,0 @@
-
-
-
-
-
-
- qcType
- 0
-
-