org.n52.shetland.ogc.sos.response

Class AbstractStreaming

java.lang.Object

org.n52.shetland.ogc.om.AbstractObservationValue<Value<ObservationStream>>

org.n52.shetland.ogc.sos.response.AbstractStreaming

All Implemented Interfaces:

AutoCloseable, ThrowingIterator<OmObservation,OwsExceptionReport>, ObservationStream, ObservationValue<Value<ObservationStream>>

Direct Known Subclasses:

StreamingValue

public abstract class AbstractStreaming
extends AbstractObservationValue<Value<ObservationStream>>
implements ObservationStream

Constructor Summary

Constructors

Constructor and Description
AbstractStreaming()

Method Summary

Modifier and Type	Method and Description
void	add(OWSConstants.AdditionalRequestParams parameter, Object object)
protected abstract void	checkForModifications(OmObservation observation) Check and modify observation for Spatial Filtering Profile and requested crs
protected void	checkMaxNumberOfReturnedValues(int size) Check if the max number of returned values is exceeded
boolean	contains(OWSConstants.AdditionalRequestParams parameter)
protected Object	getAdditionalRequestParams(OWSConstants.AdditionalRequestParams parameter)
int	getMaxNumberOfValues()
ObservationMergeIndicator	getObservationMergeIndicator()
String	getResponseFormat()
abstract boolean	hasNext()
boolean	isSetAdditionalRequestParams()
boolean	isSetValue()
abstract OmObservation	next()
void	setMaxNumberOfValues(int maxNumberOfValues)
void	setObservationMergeIndicator(ObservationMergeIndicator mergeIndicator)
void	setResponseFormat(String responseFormat)

Methods inherited from class org.n52.shetland.ogc.om.AbstractObservationValue

getDecimalSeparator, getDefaultPointMetadata, getMetadata, getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, getUnit, isSetDecimalSeparator, isSetDefaultPointMetadata, isSetMetadata, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, isSetUnit, setDecimalSeparator, setDefaultPointMetadata, setMetadata, setObservationID, setUnit, setValuesForResultEncoding

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.n52.shetland.ogc.om.ObservationStream

close, collect, empty, filter, findAny, findFirst, flatMap, map, merge, merge, modify, of, of, of, toStream

Methods inherited from interface org.n52.janmayen.ThrowingIterator

forEachRemaining, remove

Methods inherited from interface org.n52.shetland.ogc.om.ObservationValue

getPhenomenonTime, getValue, setPhenomenonTime, setValue

Constructor Detail

AbstractStreaming

public AbstractStreaming()

Method Detail

next

public abstract OmObservation next()
                            throws NoSuchElementException,
                                   OwsExceptionReport

Specified by:

next in interface ThrowingIterator<OmObservation,OwsExceptionReport>

Throws:

NoSuchElementException

OwsExceptionReport

hasNext

public abstract boolean hasNext()
                         throws OwsExceptionReport

Specified by:

hasNext in interface ThrowingIterator<OmObservation,OwsExceptionReport>

Throws:

OwsExceptionReport

checkForModifications

protected abstract void checkForModifications(OmObservation observation)
                                       throws OwsExceptionReport

Check and modify observation for Spatial Filtering Profile and requested crs

Parameters:

observation - OmObservation to check

Throws:

OwsExceptionReport - If an error occurs when modifying the OmObservation

add

public void add(OWSConstants.AdditionalRequestParams parameter,
                Object object)

contains

public boolean contains(OWSConstants.AdditionalRequestParams parameter)

isSetAdditionalRequestParams

public boolean isSetAdditionalRequestParams()

getAdditionalRequestParams

protected Object getAdditionalRequestParams(OWSConstants.AdditionalRequestParams parameter)

isSetValue

public boolean isSetValue()

Specified by:

isSetValue in interface ObservationValue<Value<ObservationStream>>

setResponseFormat

public void setResponseFormat(String responseFormat)

getResponseFormat

public String getResponseFormat()

getMaxNumberOfValues

public int getMaxNumberOfValues()

Returns:

the maxNumberOfValues

setMaxNumberOfValues

public void setMaxNumberOfValues(int maxNumberOfValues)

Parameters:

maxNumberOfValues - the maxNumberOfValues to set

checkMaxNumberOfReturnedValues

protected void checkMaxNumberOfReturnedValues(int size)
                                       throws OwsExceptionReport

Check if the max number of returned values is exceeded

Parameters:

size - Max number count

Throws:

CodedException - If the size limit is exceeded

OwsExceptionReport

setObservationMergeIndicator

public void setObservationMergeIndicator(ObservationMergeIndicator mergeIndicator)

getObservationMergeIndicator

public ObservationMergeIndicator getObservationMergeIndicator()