public abstract class AbstractStreaming extends AbstractObservationValue<Value<OmObservation>>
Modifier and Type | Field and Description |
---|---|
private Map<OWSConstants.AdditionalRequestParams,Object> |
additionalRequestParams |
private int |
currentNumberOfValues |
private int |
maxNumberOfValues |
private String |
responseFormat |
private static long |
serialVersionUID |
Constructor and Description |
---|
AbstractStreaming() |
Modifier and Type | Method and Description |
---|---|
void |
add(OWSConstants.AdditionalRequestParams parameter,
Object object) |
protected 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() |
List<OmObservation> |
getObservation() |
String |
getResponseFormat() |
abstract boolean |
hasNextValue() |
boolean |
isSetAdditionalRequestParams() |
boolean |
isSetValue() |
Collection<OmObservation> |
mergeObservation() |
abstract OmObservation |
nextSingleObservation() |
void |
setMaxNumberOfValues(int maxNumberOfValues) |
void |
setResponseFormat(String responseFormat) |
getDecimalSeparator, getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, getUnit, isSetDecimalSeparator, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, isSetUnit, setDecimalSeparator, setUnit, setValuesForResultEncoding
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPhenomenonTime, getValue, setPhenomenonTime, setValue
private static final long serialVersionUID
private Map<OWSConstants.AdditionalRequestParams,Object> additionalRequestParams
private String responseFormat
private int maxNumberOfValues
private int currentNumberOfValues
public abstract boolean hasNextValue() throws OwsExceptionReport
OwsExceptionReport
public abstract OmObservation nextSingleObservation() throws OwsExceptionReport
OwsExceptionReport
public Collection<OmObservation> mergeObservation() throws OwsExceptionReport
OwsExceptionReport
public List<OmObservation> getObservation() throws OwsExceptionReport
OwsExceptionReport
public void add(OWSConstants.AdditionalRequestParams parameter, Object object)
public boolean contains(OWSConstants.AdditionalRequestParams parameter)
public boolean isSetAdditionalRequestParams()
protected Object getAdditionalRequestParams(OWSConstants.AdditionalRequestParams parameter)
protected void checkForModifications(OmObservation observation) throws OwsExceptionReport
observation
- OmObservation
to checkOwsExceptionReport
- If an error occurs when modifying the OmObservation
public boolean isSetValue()
public void setResponseFormat(String responseFormat)
public String getResponseFormat()
public int getMaxNumberOfValues()
public void setMaxNumberOfValues(int maxNumberOfValues)
maxNumberOfValues
- the maxNumberOfValues to setprotected void checkMaxNumberOfReturnedValues(int size) throws CodedException
size
- Max number countCodedException
- If the size limit is exceededCopyright © 2012-2015 52north.org. All Rights Reserved.