public class HibernateChunkStreamingValue extends HibernateStreamingValue
Modifier and Type | Field and Description |
---|---|
private int |
chunkSize |
private int |
currentRow |
private boolean |
noChunk |
private static long |
serialVersionUID |
private Iterator<AbstractValue> |
valuesResult |
featureOfInterest, observableProperty, procedure, valueDAO, valueTimeDAO
observationTemplate, request, session, sessionHolder, temporalFilterCriterion
Constructor and Description |
---|
HibernateChunkStreamingValue(GetObservationRequest request,
long procedure,
long observableProperty,
long featureOfInterest)
constructor
|
Modifier and Type | Method and Description |
---|---|
private void |
getNextResults()
Get the next results from database
|
boolean |
hasNextValue() |
OmObservation |
nextSingleObservation() |
TimeValuePair |
nextValue() |
void |
setObservationTemplate(OmObservation observationTemplate)
Set the observation template which contains all metadata
|
private void |
setObservationValuesResult(Collection<AbstractValue> valuesResult)
Check the queried
AbstractValue s for null and set them as
iterator to local variable. |
queryTimes, queryUnit
addValuesToObservation, createPhenomenonTime, createPhenomenonTime, createResutlTime, createResutlTime, createSpatialFilteringProfileParameter, createTime, createTimeValuePairFrom, createValidTime, createValidTime, getObservationIds, getSpatialFilteringProfileAdder, getValueFrom, isSetSpatialFilteringProfileAdder, 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 Iterator<AbstractValue> valuesResult
private int chunkSize
private int currentRow
private boolean noChunk
public HibernateChunkStreamingValue(GetObservationRequest request, long procedure, long observableProperty, long featureOfInterest)
request
- GetObservationRequest
procedure
- Datasource procedure idobservableProperty
- Datasource observableProperty idfeatureOfInterest
- Datasource featureOfInterest 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
public void setObservationTemplate(OmObservation observationTemplate)
AbstractHibernateStreamingValue
setObservationTemplate
in class AbstractHibernateStreamingValue
observationTemplate
- Observation template to setprivate void getNextResults() throws OwsExceptionReport
OwsExceptionReport
- If an error occurs when querying the next resultsprivate void setObservationValuesResult(Collection<AbstractValue> valuesResult)
AbstractValue
s for null and set them as
iterator to local variable.valuesResult
- Queried AbstractValue
sCopyright © 2012-2014 52north.org. All Rights Reserved.