public abstract class AbstractHibernateStreamingObservation extends StreamingObservation
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
features |
protected boolean |
observationNotQueried |
protected GetObservationRequest |
request |
protected org.hibernate.ScrollableResults |
result |
private static long |
serialVersionUID |
protected org.hibernate.Session |
session |
protected HibernateSessionHolder |
sessionHolder |
protected boolean |
showMetadataOfEmptyObservation |
protected org.hibernate.criterion.Criterion |
temporalFilterCriterion |
Constructor and Description |
---|
AbstractHibernateStreamingObservation(GetObservationRequest request)
constructor
|
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractObservation |
checkShowMetadtaOfEmptyObservations(AbstractObservation abstractObservation)
Check if metadata fo emtpy observations should be show in the response
and store required information
|
protected abstract void |
getNextScrollableResults()
Get the next
ScrollableResults from database |
boolean |
hasNextValue() |
OmObservation |
nextSingleObservation() |
protected void |
setResult(org.hibernate.ScrollableResults result)
Set the scrollable result
|
void |
setTemporalFilterCriterion(org.hibernate.criterion.Criterion temporalFilterCriterion)
Set the temporal filter
Criterion |
void |
setValidFeatures(Set<String> features)
Set the valid featureOfInterest identifiers
|
getPhenomenonTime, getValue, setPhenomenonTime, setValue
add, checkForModifications, checkMaxNumberOfReturnedValues, contains, getAdditionalRequestParams, getMaxNumberOfValues, getObservation, getResponseFormat, isSetAdditionalRequestParams, isSetValue, mergeObservation, setMaxNumberOfValues, setResponseFormat
getDecimalSeparator, getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, getUnit, isSetDecimalSeparator, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, isSetUnit, setDecimalSeparator, setUnit, setValuesForResultEncoding
private static final long serialVersionUID
protected final HibernateSessionHolder sessionHolder
protected org.hibernate.Session session
protected org.hibernate.ScrollableResults result
protected GetObservationRequest request
protected org.hibernate.criterion.Criterion temporalFilterCriterion
protected boolean showMetadataOfEmptyObservation
protected boolean observationNotQueried
public AbstractHibernateStreamingObservation(GetObservationRequest request)
request
- GetObservationRequest
public boolean hasNextValue() throws OwsExceptionReport
hasNextValue
in class AbstractStreaming
OwsExceptionReport
public OmObservation nextSingleObservation() throws OwsExceptionReport
nextSingleObservation
in class AbstractStreaming
OwsExceptionReport
protected void setResult(org.hibernate.ScrollableResults result)
result
- ScrollableResults
to setpublic void setValidFeatures(Set<String> features)
features
- featureOfInterest identifiers to setpublic void setTemporalFilterCriterion(org.hibernate.criterion.Criterion temporalFilterCriterion)
Criterion
temporalFilterCriterion
- Temporal filter Criterion
protected abstract AbstractObservation checkShowMetadtaOfEmptyObservations(AbstractObservation abstractObservation)
abstractObservation
- Observation to checkprotected abstract void getNextScrollableResults() throws OwsExceptionReport
ScrollableResults
from databaseOwsExceptionReport
- If an error occurs when querying the databaseCopyright © 2012-2015 52north.org. All Rights Reserved.