public class HibernateScrollableSeriesStreamingValue extends HibernateSeriesStreamingValue
ScrollableResults
Modifier and Type | Field and Description |
---|---|
private org.hibernate.ScrollableResults |
scrollableResult |
private static long |
serialVersionUID |
series, seriesValueDAO, seriesValueTimeDAO
observationTemplate, request, session, sessionHolder, temporalFilterCriterion
Constructor and Description |
---|
HibernateScrollableSeriesStreamingValue(GetObservationRequest request,
long series)
constructor
|
Modifier and Type | Method and Description |
---|---|
private void |
addSpatialFilteringProfile(OmObservation observation,
Long oId)
Query and add Spatial Filtering Profile information to observation
|
private void |
getNextResults()
Get the next results from database
|
boolean |
hasNextValue() |
OmObservation |
nextSingleObservation() |
TimeValuePair |
nextValue() |
private void |
setScrollableResult(org.hibernate.ScrollableResults scrollableResult)
Set the queried
ScrollableResults to local variable |
queryTimes, queryUnit
addValuesToObservation, createPhenomenonTime, createPhenomenonTime, createResutlTime, createResutlTime, createSpatialFilteringProfileParameter, createTime, createTimeValuePairFrom, createValidTime, createValidTime, getObservationIds, getSpatialFilteringProfileAdder, getValueFrom, isSetSpatialFilteringProfileAdder, setObservationTemplate, setSpatialFilteringProfileAdder, setTemporalFilterCriterion
getPhenomenonTime, getResultTime, getUnit, getValidTime, getValue, isSetPhenomenonTime, isSetResultTime, isSetUnit, isSetValidTime, setPhenomenonTime, setResultTime, setUnit, setValidTime, setValue
getObservation, mergeObservation
getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, setValuesForResultEncoding
private static final long serialVersionUID
private org.hibernate.ScrollableResults scrollableResult
public HibernateScrollableSeriesStreamingValue(GetObservationRequest request, long series)
request
- GetObservationRequest
series
- Datasource series idpublic boolean hasNextValue() throws OwsExceptionReport
hasNextValue
in class AbstractStreaming
OwsExceptionReport
public TimeValuePair nextValue() throws OwsExceptionReport
nextValue
in class StreamingValue
OwsExceptionReport
public OmObservation nextSingleObservation() throws OwsExceptionReport
nextSingleObservation
in class AbstractStreaming
OwsExceptionReport
private void addSpatialFilteringProfile(OmObservation observation, Long oId) throws OwsExceptionReport
observation
- Observation to add Spatial Filtering Profile informationoId
- Datasource observation idOwsExceptionReport
- If an error occurs when querying the Spatial Filtering
Profile information or during the addingprivate void getNextResults() throws OwsExceptionReport
OwsExceptionReport
- If an error occurs when querying the next resultsprivate void setScrollableResult(org.hibernate.ScrollableResults scrollableResult)
ScrollableResults
to local variablescrollableResult
- Queried ScrollableResults
Copyright © 2012-2014 52north.org. All Rights Reserved.