public class OfferingCacheUpdate extends AbstractQueueingDatasourceCacheUpdate<OfferingCacheUpdateTask>
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOGGER |
private OfferingDAO |
offeringDAO |
private Collection<String> |
offeringsIdToUpdate |
private Collection<Offering> |
offeringsToUpdate |
private Map<String,Collection<ObservationConstellationInfo>> |
offObsConstInfoMap |
private static String |
THREAD_GROUP_NAME |
Constructor and Description |
---|
OfferingCacheUpdate(int threads)
constructor
|
OfferingCacheUpdate(int threads,
Collection<String> offeringIdsToUpdate) |
Modifier and Type | Method and Description |
---|---|
private boolean |
checkForSamplingGeometry()
Check if the observation table contains samplingGeometries with values.
|
void |
execute() |
protected Collection<String> |
getFeatureOfInterestTypesFromFeatureOfInterestType(Set<FeatureOfInterestType> featureOfInterestTypes) |
protected Set<String> |
getObservationTypesFromObservationType(Set<ObservationType> observationTypes) |
private Map<String,Collection<ObservationConstellationInfo>> |
getOfferingObservationConstellationInfo() |
private Collection<Offering> |
getOfferingsToUpdate() |
protected Set<String> |
getRelatedFeatureIdentifiersFrom(TOffering hOffering) |
protected OfferingCacheUpdateTask[] |
getUpdatesToExecute() |
protected boolean |
shouldOfferingBeProcessed(String offeringIdentifier) |
getSession, setSession
getCache, getErrors, getFeatureQueryHandler, setCache, setErrors, toString
run, setParentCountDownLatch
getStopwatchResult, startStopwatch
private static final org.slf4j.Logger LOGGER
private static final String THREAD_GROUP_NAME
private final OfferingDAO offeringDAO
private Collection<String> offeringsIdToUpdate
private Collection<Offering> offeringsToUpdate
private Map<String,Collection<ObservationConstellationInfo>> offObsConstInfoMap
public OfferingCacheUpdate(int threads)
threads
- Thread countpublic OfferingCacheUpdate(int threads, Collection<String> offeringIdsToUpdate)
private Collection<Offering> getOfferingsToUpdate()
private Map<String,Collection<ObservationConstellationInfo>> getOfferingObservationConstellationInfo()
public void execute()
execute
in interface Action
execute
in class AbstractQueueingDatasourceCacheUpdate<OfferingCacheUpdateTask>
protected OfferingCacheUpdateTask[] getUpdatesToExecute() throws OwsExceptionReport
getUpdatesToExecute
in class AbstractQueueingDatasourceCacheUpdate<OfferingCacheUpdateTask>
OwsExceptionReport
private boolean checkForSamplingGeometry()
true
, if the observation table contains samplingGeometries with valuesprotected boolean shouldOfferingBeProcessed(String offeringIdentifier)
protected Set<String> getObservationTypesFromObservationType(Set<ObservationType> observationTypes)
protected Collection<String> getFeatureOfInterestTypesFromFeatureOfInterestType(Set<FeatureOfInterestType> featureOfInterestTypes)
Copyright © 2012-2015 52north.org. All Rights Reserved.