public class OfferingCacheUpdateTask extends AbstractThreadableDatasourceCacheUpdate
Modifier and Type | Field and Description |
---|---|
private FeatureOfInterestDAO |
featureDAO |
private static org.slf4j.Logger |
LOGGER |
private boolean |
obsConstSupported |
private Collection<ObservationConstellationInfo> |
observationConstellationInfos |
private String |
offeringId |
Constructor and Description |
---|
OfferingCacheUpdateTask(String dsOfferingId,
Collection<ObservationConstellationInfo> observationConstellationInfos)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addSpatialFilteringProfileEnvelopeForOffering(String prefixedOfferingId,
String offeringID,
org.hibernate.Session session)
Get SpatialFilteringProfile envelope if exist and supported
|
void |
execute() |
protected SosEnvelope |
getEnvelopeForOffering(Collection<String> featureOfInterestIdentifiers,
org.hibernate.Session session) |
protected Set<String> |
getFeatureOfInterestTypes(List<String> featureOfInterestIdentifiers,
org.hibernate.Session session) |
protected Set<String> |
getObservablePropertyIdentifier(org.hibernate.Session session) |
protected Set<String> |
getObservationTypes(org.hibernate.Session session) |
private Set<String> |
getObservationTypesFromObservations(org.hibernate.Session session) |
protected void |
getOfferingInformationFromDbAndAddItToCacheMaps(org.hibernate.Session session) |
protected Map<ProcedureFlag,Set<String>> |
getProcedureIdentifiers(org.hibernate.Session session) |
protected Collection<String> |
getValidFeaturesOfInterestFrom(Collection<String> featureOfInterestIdentifiers) |
getSession, getSessionFactory, setSessionFactory
setSession
getCache, getErrors, getFeatureQueryHandler, setCache, setErrors, toString
run, setParentCountDownLatch
getStopwatchResult, startStopwatch
private static final org.slf4j.Logger LOGGER
private FeatureOfInterestDAO featureDAO
private String offeringId
private Collection<ObservationConstellationInfo> observationConstellationInfos
private boolean obsConstSupported
public OfferingCacheUpdateTask(String dsOfferingId, Collection<ObservationConstellationInfo> observationConstellationInfos)
dsOfferingId
- Offering identifierobservationConstellatinInfos
- Observation Constellation info collection, passed in from parent update if supportedprotected void getOfferingInformationFromDbAndAddItToCacheMaps(org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
protected Map<ProcedureFlag,Set<String>> getProcedureIdentifiers(org.hibernate.Session session) throws CodedException
CodedException
protected Collection<String> getValidFeaturesOfInterestFrom(Collection<String> featureOfInterestIdentifiers)
protected Set<String> getObservablePropertyIdentifier(org.hibernate.Session session) throws CodedException
CodedException
protected Set<String> getObservationTypes(org.hibernate.Session session) throws CodedException
CodedException
private Set<String> getObservationTypesFromObservations(org.hibernate.Session session) throws CodedException
CodedException
protected Set<String> getFeatureOfInterestTypes(List<String> featureOfInterestIdentifiers, org.hibernate.Session session)
protected SosEnvelope getEnvelopeForOffering(Collection<String> featureOfInterestIdentifiers, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
protected void addSpatialFilteringProfileEnvelopeForOffering(String prefixedOfferingId, String offeringID, org.hibernate.Session session) throws OwsExceptionReport
offeringID
- Offering identifier used in requests and responsesofferingID
- Database Offering identifier to get envelope forsession
- Hibernate sessionOwsExceptionReport
- If an error occurspublic void execute()
Copyright © 2012-2014 52north.org. All Rights Reserved.