public class HibernateChunkSeriesStreamingValue extends HibernateSeriesStreamingValue
Modifier and Type | Field and Description |
---|---|
private int |
chunkSize |
private int |
currentResultSize |
private int |
currentRow |
private boolean |
noChunk |
private static long |
serialVersionUID |
private Iterator<AbstractValue> |
seriesValuesResult |
series, seriesValueDAO, seriesValueTimeDAO
request, session, sessionHolder, temporalFilterCriterion
observationTemplate
Constructor and Description |
---|
HibernateChunkSeriesStreamingValue(GetObservationRequest request,
long series)
constructor
|
Modifier and Type | Method and Description |
---|---|
private void |
getNextResults()
Get the next results from database
|
boolean |
hasNextValue() |
AbstractValue |
nextEntity()
Get the next entity
|
OmObservation |
nextSingleObservation() |
TimeValuePair |
nextValue()
Get next
TimeValuePair from entity |
private void |
setSeriesValuesResult(Collection<AbstractValue> seriesValuesResult)
Check the queried
AbstractValue s for null and set them as
iterator to local variable. |
queryTimes, queryUnit
createPhenomenonTime, createResutlTime, createValidTime, getObservationIds, mergeObservation, setTemporalFilterCriterion
getPhenomenonTime, getResultTime, getUnit, getValidTime, getValue, isSetPhenomenonTime, isSetResultTime, isSetUnit, isSetValidTime, setObservationTemplate, setPhenomenonTime, setResultTime, setUnit, setValidTime, setValue
add, checkForModifications, checkMaxNumberOfReturnedValues, contains, getAdditionalRequestParams, getMaxNumberOfValues, getObservation, getResponseFormat, isSetAdditionalRequestParams, isSetValue, setMaxNumberOfValues, setResponseFormat
getDecimalSeparator, getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, isSetDecimalSeparator, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, setDecimalSeparator, setValuesForResultEncoding
private static final long serialVersionUID
private Iterator<AbstractValue> seriesValuesResult
private int chunkSize
private int currentRow
private boolean noChunk
private int currentResultSize
public HibernateChunkSeriesStreamingValue(GetObservationRequest request, long series) throws CodedException
request
- GetObservationRequest
series
- Datasource series idCodedException
public boolean hasNextValue() throws OwsExceptionReport
hasNextValue
in class AbstractStreaming
OwsExceptionReport
public AbstractValue nextEntity() throws OwsExceptionReport
StreamingValue
nextEntity
in class StreamingValue<AbstractValue>
OwsExceptionReport
- If an error occurspublic TimeValuePair nextValue() throws OwsExceptionReport
StreamingValue
TimeValuePair
from entitynextValue
in class StreamingValue<AbstractValue>
TimeValuePair
OwsExceptionReport
- If an error occurspublic OmObservation nextSingleObservation() throws OwsExceptionReport
nextSingleObservation
in class AbstractStreaming
OwsExceptionReport
private void getNextResults() throws OwsExceptionReport
OwsExceptionReport
- If an error occurs when querying the next resultsprivate void setSeriesValuesResult(Collection<AbstractValue> seriesValuesResult)
AbstractValue
s for null and set them as
iterator to local variable.seriesValuesResult
- Queried AbstractValue
sCopyright © 2012-2015 52north.org. All Rights Reserved.