Package org.n52.shetland.ogc.om

Class StreamingValue<S>

java.lang.Object

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

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

org.n52.shetland.ogc.om.StreamingValue<S>

Type Parameters:

S - Entity type

All Implemented Interfaces:

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

public abstract class StreamingValue<S>
extends AbstractStreaming

Abstract streaming value class

Since:

1.0.0

Constructor Summary

Constructors

Constructor	Description
StreamingValue()

Method Summary

Modifier and Type	Method	Description
protected void	checkForModifications(OmObservation observation)	Check and modify observation for Spatial Filtering Profile and requested crs
protected GeometryTransformer	getGeometryTransformer()
OmObservation	getObservationTemplate()
Time	getPhenomenonTime()	Get phenomenon or sampling time of the observation
TimeInstant	getResultTime()
String	getUnit()
Time	getValidTime()
Value<ObservationStream>	getValue()	Get observation value
boolean	isSetPhenomenonTime()
boolean	isSetResultTime()
boolean	isSetUnit()
boolean	isSetValidTime()
abstract S	nextEntity()	Get the next entity
abstract TimeValuePair	nextValue()	Get next TimeValuePair from entity
protected abstract void	queryTimes()	Query times
protected abstract void	queryUnit()	query unit
void	setGeometryTransformer(GeometryTransformer geometryTransformer)
void	setObservationTemplate(OmObservation observationTemplate)	Set the observation template which contains all metadata
void	setPhenomenonTime(Time phenomenonTime)	Set phenomenon or sampling time of the observation
protected void	setResultTime(TimeInstant resultTime)
void	setUnit(String unit)
protected void	setValidTime(Time validTime)
void	setValue(Value<ObservationStream> value)	Set observation value

Methods inherited from class org.n52.shetland.ogc.sos.response.AbstractStreaming

add, checkMaxNumberOfReturnedValues, contains, getAdditionalRequestParams, getMaxNumberOfValues, getObservationMergeIndicator, getResponseFormat, hasNext, isSetAdditionalRequestParams, isSetValue, next, setMaxNumberOfValues, setObservationMergeIndicator, setResponseFormat

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

getDecimalSeparator, getDefaultPointMetadata, getMetadata, getObservableProperty, getObservationID, getObservationType, getTokenSeparator, getTupleSeparator, isSetDecimalSeparator, isSetDefaultPointMetadata, isSetMetadata, isSetObservablePropertyD, isSetObservationID, isSetObservationType, isSetTokenSeparator, isSetTupleSeparator, setDecimalSeparator, setDefaultPointMetadata, setMetadata, setObservationID, 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, filter, findAny, findFirst, flatMap, map, merge, merge, modify, toStream

Methods inherited from interface org.n52.janmayen.ThrowingIterator

forEachRemaining, remove

Constructor Detail

StreamingValue

public StreamingValue()

Method Detail

nextEntity

public abstract S nextEntity()
                      throws OwsExceptionReport

Get the next entity

Returns:

next entity object

Throws:

OwsExceptionReport - If an error occurs

queryTimes

protected abstract void queryTimes()

Query times

queryUnit

protected abstract void queryUnit()

query unit

nextValue

public abstract TimeValuePair nextValue()
                                 throws OwsExceptionReport

Get next TimeValuePair from entity

Returns:

Next TimeValuePair

Throws:

OwsExceptionReport - If an error occurs

getGeometryTransformer

protected GeometryTransformer getGeometryTransformer()

setGeometryTransformer

public void setGeometryTransformer(GeometryTransformer geometryTransformer)

Parameters:

geometryTransformer - the geometryTransformer to set

setObservationTemplate

public void setObservationTemplate(OmObservation observationTemplate)

Set the observation template which contains all metadata

Parameters:

observationTemplate - Observation template to set

getObservationTemplate

public OmObservation getObservationTemplate()

Returns:

the observationTemplate

getPhenomenonTime

public Time getPhenomenonTime()

Description copied from interface: ObservationValue

Get phenomenon or sampling time of the observation

Returns:

Phenomenon or sampling time of the observation

setPhenomenonTime

public void setPhenomenonTime(Time phenomenonTime)

Description copied from interface: ObservationValue

Set phenomenon or sampling time of the observation

Parameters:

phenomenonTime - Phenomenon or sampling time of the observation

isSetPhenomenonTime

public boolean isSetPhenomenonTime()

getValue

public Value<ObservationStream> getValue()

Description copied from interface: ObservationValue

Get observation value

Returns:

Observation value

setValue

public void setValue(Value<ObservationStream> value)

Description copied from interface: ObservationValue

Set observation value

Parameters:

value - Observation value

getUnit

public String getUnit()

Overrides:

getUnit in class AbstractObservationValue<Value<ObservationStream>>

Returns:

the unit

setUnit

public void setUnit(String unit)

Overrides:

setUnit in class AbstractObservationValue<Value<ObservationStream>>

Parameters:

unit - the unit to set

isSetUnit

public boolean isSetUnit()

Overrides:

isSetUnit in class AbstractObservationValue<Value<ObservationStream>>

getResultTime

public TimeInstant getResultTime()

setResultTime

protected void setResultTime(TimeInstant resultTime)

isSetResultTime

public boolean isSetResultTime()

getValidTime

public Time getValidTime()

setValidTime

protected void setValidTime(Time validTime)

isSetValidTime

public boolean isSetValidTime()

checkForModifications

protected void checkForModifications(OmObservation observation)
                              throws OwsExceptionReport

Description copied from class: AbstractStreaming

Check and modify observation for Spatial Filtering Profile and requested crs

Specified by:

checkForModifications in class AbstractStreaming

Parameters:

observation - OmObservation to check

Throws:

OwsExceptionReport - If an error occurs when modifying the OmObservation